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) | flink | 7a09b55e7434869894ce35614cd7bf9589052a44 | org.apache.flink.streaming.runtime.io.AlternatingCheckpointBarrierHandlerTest | | | | | | Uses | False |