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 822e8a3 [FLINK-18152][Depl] Fail fast in JM scripts if memory
configuration failed
add b552ff2 [hotfix][checkpointing] Add VisibleForTesting annotation for
related methods
add 9860579 [FLINK-18063][checkpointing][refactoring] Implement default
#isBlocked method in CheckpointBarrierHandler
add 587a399 [FLINK-18063][checkpointing] Fix the invalid implementation
of AlternatingCheckpointBarrierHandler#getAlignmentDurationNanos
add 2fe888c [FLINK-18063][checkpointing] Fix the race condition of
aborting checkpoint in CheckpointBarrierUnaligner
No new revisions were added by this update.
Summary of changes:
.../io/AlternatingCheckpointBarrierHandler.java | 21 ++--
.../runtime/io/CheckpointBarrierAligner.java | 8 ++
.../runtime/io/CheckpointBarrierHandler.java | 14 ++-
.../runtime/io/CheckpointBarrierTracker.java | 14 ---
.../runtime/io/CheckpointBarrierUnaligner.java | 126 ++++++++++----------
.../runtime/io/CheckpointedInputGate.java | 3 +-
...CheckpointBarrierUnalignerCancellationTest.java | 2 +-
.../runtime/io/CheckpointBarrierUnalignerTest.java | 129 ++++++++++++++++++++-
8 files changed, 222 insertions(+), 95 deletions(-)
