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 babb692 [FLINK-23569][docs] Fix typo new 3ccd984 [hotfix][runtime][checkpoint] Rename isFinished to isFinishedOnRestore for task state new 66bf4e6 [FLINK-21080][runtime][checkpoint] The task reports whether it has called operators' finish method new 0182cd3 [FLINK-21080][runtime][checkpoint] Fails checkpoints if some operators has union state are partly finished new 2f5655a [FLINK-21080][runtime][checkpoint] Report latest completed checkpoint id when notifying checkpoint abort The 4 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: .../runtime/checkpoint/CheckpointCoordinator.java | 6 +- .../flink/runtime/checkpoint/CheckpointPlan.java | 11 +- .../checkpoint/CompletedCheckpointStore.java | 15 +++ .../DefaultCheckpointPlanCalculator.java | 6 +- .../runtime/checkpoint/PendingCheckpoint.java | 131 +++++++++++++++++++- .../checkpoint/StateAssignmentOperation.java | 5 +- .../runtime/checkpoint/TaskStateSnapshot.java | 44 ++++--- .../flink/runtime/executiongraph/Execution.java | 10 +- .../runtime/jobgraph/tasks/AbstractInvokable.java | 4 +- .../jobmanager/slots/TaskManagerGateway.java | 7 +- .../runtime/jobmaster/RpcTaskManagerGateway.java | 9 +- .../runtime/state/TaskLocalStateStoreImpl.java | 2 +- .../flink/runtime/state/TaskStateManagerImpl.java | 2 +- .../flink/runtime/taskexecutor/TaskExecutor.java | 7 +- .../runtime/taskexecutor/TaskExecutorGateway.java | 6 +- .../TaskExecutorGatewayDecoratorBase.java | 7 +- .../org/apache/flink/runtime/taskmanager/Task.java | 14 +-- .../checkpoint/CheckpointCoordinatorTest.java | 72 +++++++++++ .../CheckpointCoordinatorTestingUtils.java | 30 ++++- .../checkpoint/CompletedCheckpointStoreTest.java | 15 +++ .../runtime/checkpoint/PendingCheckpointTest.java | 136 ++++++++++++++++++++- .../checkpoint/StateAssignmentOperationTest.java | 4 +- .../utils/SimpleAckingTaskManagerGateway.java | 1 + .../CoordinatorEventsExactlyOnceITCase.java | 3 +- .../runtime/state/TaskStateManagerImplTest.java | 2 +- .../flink/runtime/state/TestTaskStateManager.java | 2 +- .../taskexecutor/TestingTaskExecutorGateway.java | 5 +- .../runtime/tasks/AsyncCheckpointRunnable.java | 11 +- .../flink/streaming/runtime/tasks/StreamTask.java | 20 ++- .../tasks/SubtaskCheckpointCoordinator.java | 1 + .../tasks/SubtaskCheckpointCoordinatorImpl.java | 4 + .../runtime/tasks/AsyncCheckpointRunnableTest.java | 6 +- .../runtime/tasks/LocalStateForwardingTest.java | 1 + ...tStreamTaskChainedSourcesCheckpointingTest.java | 2 +- .../tasks/SourceOperatorStreamTaskTest.java | 2 +- .../runtime/tasks/SourceStreamTaskTest.java | 2 +- .../tasks/StreamTaskFinalCheckpointsTest.java | 98 ++++++++++++++- .../streaming/runtime/tasks/StreamTaskTest.java | 66 +++++++++- .../tasks/SubtaskCheckpointCoordinatorTest.java | 7 ++ .../runtime/tasks/SynchronousCheckpointITCase.java | 3 +- .../tasks/TestSubtaskCheckpointCoordinator.java | 1 + .../JobMasterStopWithSavepointITCase.java | 3 +- .../jobmaster/JobMasterTriggerSavepointITCase.java | 3 +- 43 files changed, 711 insertions(+), 75 deletions(-)