This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7143e6a [FLINK-17944][sql-client] Wrong output in SQL Client's table
mode
add 1cb9d54 [FLINK-17869][hotfix] Add taskName to ChannelStateWriter log
messages
add 82a13db [FLINK-17869][hotfix] Don't pass ChannelStateWrite Future to
AsyncCheckpointRunnable
add 73afe2b [FLINK-17869][task][checkpointing] Revert
"[FLINK-17218][checkpointing] Ensuring that ChannelStateWriter aborts previous
checkpoints before a new checkpoint is started."
add 91df1a5 [FLINK-17869][task][checkpointing] Abort channel state write
if checkpoint is subsumed
add 2b51cda [FLINK-17869][task][checkpointing] Increase
ChannelStateWriterImpl.DEFAULT_MAX_CHECKPOINTS
add 64ff676 [FLINK-17869][task][checkpointing] Ignore out of order
checkpoints in SubtaskCheckpointCoordinator
add 26762bd1 [FLINK-17869][tests] Unignore UnalignedCheckpointITCase
add b2d1c2d [FLINK-17869][task][checkpointing] Abort writing of channel
state by RPC notification
No new revisions were added by this update.
Summary of changes:
.../checkpoint/channel/ChannelStateWriter.java | 29 +++++-------
.../checkpoint/channel/ChannelStateWriterImpl.java | 25 ++++------
.../channel/ChannelStateWriterImplTest.java | 49 +++++++++-----------
.../checkpoint/channel/MockChannelStateWriter.java | 8 +---
.../channel/RecordingChannelStateWriter.java | 5 --
.../runtime/state/ChannelPersistenceITCase.java | 2 +-
.../runtime/io/CheckpointBarrierUnaligner.java | 31 +++++++------
.../runtime/tasks/AsyncCheckpointRunnable.java | 6 ---
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 54 +++++++++++++---------
.../runtime/tasks/LocalStateForwardingTest.java | 2 -
.../tasks/TestSubtaskCheckpointCoordinator.java | 2 +-
.../checkpointing/UnalignedCheckpointITCase.java | 2 -
12 files changed, 95 insertions(+), 120 deletions(-)
