This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cc59b3a [FLINK-18020] Increase timeout in SQLClientKafkaITCase
add b2852d3 [FLINK-18139][checkpointing] Fixing unaligned checkpoints
checks wrong channels for inflight data.
No new revisions were added by this update.
Summary of changes:
.../partition/consumer/SingleInputGateBuilder.java | 4 +-
.../io/AlternatingCheckpointBarrierHandler.java | 5 +-
.../runtime/io/CheckpointBarrierHandler.java | 3 +-
.../runtime/io/CheckpointBarrierUnaligner.java | 4 +-
.../runtime/io/CheckpointedInputGate.java | 5 +-
.../AlternatingCheckpointBarrierHandlerTest.java | 4 +-
.../runtime/io/StreamTaskNetworkInputTest.java | 73 +++++++++++++++++++++-
7 files changed, 85 insertions(+), 13 deletions(-)
