return new LongSourceReader(minCheckpoints,expectedRestarts); | return new LongSourceReader(readerContext.getIndexOfSubtask(),minCheckpoints,expectedRestarts); | new LongSourceReader(minCheckpoints,expectedRestarts) | new LongSourceReader(readerContext.getIndexOfSubtask(),minCheckpoints,expectedRestarts) | flink | 29abccd4cb7d4905fa168f8d7b68a113e9640fca | org.apache.flink.test.checkpointing.UnalignedCheckpointTestBase.LongSource | | _1 | minCheckpoints |
---|
_2 | minCheckpoints |
---|
| TCIVar | minCheckpoints |
---|
v1 | expectedRestarts |
---|
| | TCIVar | minCheckpoints |
---|
v1 | expectedRestarts |
---|
| Uses | False |