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 31a17cb [FLINK-18188][Runtime] Derive JM Off-Heap memory from
configured Total Flink Memory minus JVM Heap
new 4030b1b [FLINK-17869][hotfix] Add taskName to ChannelStateWriter log
messages
new 36609bb [FLINK-17869][hotfix] Don't pass ChannelStateWrite Future to
AsyncCheckpointRunnable
new 6cb8f28 [FLINK-17869][task][checkpointing] Revert
"[FLINK-17218][checkpointing] Ensuring that ChannelStateWriter aborts previous
checkpoints before a new checkpoint is started."
new d806924 [FLINK-17869][task][checkpointing] Abort channel state write
if checkpoint is subsumed
new e14958d [FLINK-17869][task][checkpointing] Increase
ChannelStateWriterImpl.DEFAULT_MAX_CHECKPOINTS
new 7bb3ffa [FLINK-17869][task][checkpointing] Ignore out of order
checkpoints in SubtaskCheckpointCoordinator
new 0634a2e [FLINK-17869][tests] Unignore UnalignedCheckpointITCase
new 1d75ec8 [FLINK-17869][task][checkpointing] Abort writing of channel
state by RPC notification
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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(-)
