| 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 |