OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
assertEquals(activeHandler.hasInflightData(i,channelId),barrierHandler.hasInflightData(i,channelId));assertEquals(expected.hasInflightData(barrierId,channelId),actual.hasInflightData(barrierId,channelId));activeHandler.hasInflightData(i,channelId)expected.hasInflightData(i,channelId)flink7a09b55e7434869894ce35614cd7bf9589052a44org.apache.flink.streaming.runtime.io.AlternatingCheckpointBarrierHandlerTest
_195
_2108
_1i
_2barrierId
TCIVari
v1channelId
TCIVari
v1channelId
UsesFalse