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 95ea0da [FLINK-23276][state/changelog] Fix missing delegation in
getPartitionedState
add 6ce2f45 [FLINK-21087][runtime][checkpoint] StreamTask waits for all
the pending checkpoints to finish before finished
No new revisions were added by this update.
Summary of changes:
.../runtime/tasks/AsyncCheckpointRunnable.java | 14 ++--
.../flink/streaming/runtime/tasks/StreamTask.java | 4 ++
.../tasks/SubtaskCheckpointCoordinator.java | 3 +
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 52 +++++++++-----
.../runtime/tasks/AsyncCheckpointRunnableTest.java | 2 -
.../runtime/tasks/LocalStateForwardingTest.java | 1 -
...tStreamTaskChainedSourcesCheckpointingTest.java | 4 +-
.../runtime/tasks/MultipleInputStreamTaskTest.java | 4 +-
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 10 +++
.../streaming/runtime/tasks/StreamTaskTest.java | 84 +++++++++++++++++++++-
.../tasks/TestSubtaskCheckpointCoordinator.java | 3 +
11 files changed, 150 insertions(+), 31 deletions(-)
