This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 62a342b [FLINK-22676][coordination] The partition tracker stops
tracking internal partitions when TM disconnects
add d9cc268 [FLINK-21084][runtime][checkpoint] Task reports finished
snapshot on checkpoint if it is finished on restore
add c46b203 [FLINK-21084][runtime][checkpoint] CheckpointCoordinator
records finished state for operators in tasks finished on restore
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/PendingCheckpoint.java | 72 +++++++++-----
.../runtime/checkpoint/TaskStateSnapshot.java | 8 +-
.../runtime/checkpoint/PendingCheckpointTest.java | 51 +++++++++-
.../runtime/tasks/AsyncCheckpointRunnable.java | 104 ++++++++++++++-------
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 9 +-
.../runtime/tasks/AsyncCheckpointRunnableTest.java | 34 ++++++-
.../runtime/tasks/LocalStateForwardingTest.java | 1 +
7 files changed, 214 insertions(+), 65 deletions(-)
