This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 150fa9e [FLINK-17161][docs][docker] Document the official docker hub
image and examples of how to use it
add 24ff415 [FLINK-17218][checkpointing] Ensuring that ChannelStateWriter
aborts previous checkpoints before a new checkpoint is started.
add 89446fa [FLINK-17218][checkpointing] Cleaning up ChannelStateWriter
state after all data has been written and after sync checkpoint failure.
add cd1f858 [FLINK-17218][tests] Adding recoverable failures and
correctness checks to UnalignedCheckpointITCase.
No new revisions were added by this update.
Summary of changes:
.../checkpoint/channel/ChannelStateWriter.java | 14 +-
.../checkpoint/channel/ChannelStateWriterImpl.java | 3 +-
.../channel/ChannelStateWriterImplTest.java | 21 +-
.../checkpoint/channel/MockChannelStateWriter.java | 2 +-
.../channel/RecordingChannelStateWriter.java | 2 +-
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 7 +-
.../checkpointing/UnalignedCheckpointITCase.java | 381 ++++++++++++++++++---
7 files changed, 362 insertions(+), 68 deletions(-)
