OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return new LongSourceReader(minCheckpoints,expectedRestarts);return new LongSourceReader(readerContext.getIndexOfSubtask(),minCheckpoints,expectedRestarts);new LongSourceReader(minCheckpoints,expectedRestarts)new LongSourceReader(readerContext.getIndexOfSubtask(),minCheckpoints,expectedRestarts)flink29abccd4cb7d4905fa168f8d7b68a113e9640fcaorg.apache.flink.test.checkpointing.UnalignedCheckpointTestBase.LongSource
_1155
_2158
_1minCheckpoints
_2minCheckpoints
TCIVarminCheckpoints
v1expectedRestarts
TCIVarminCheckpoints
v1expectedRestarts
UsesFalse