You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ta...@apache.org on 2021/01/28 10:03:57 UTC
[flink] branch master updated (9ce6bf7 -> f421c6f)
This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9ce6bf7 Fix typo in kinesis-connector module
add be6eb95 [FLINK-20675][checkpointing] Only decline async checkpoint failure when task is still running
add c7ed2e8 [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default
add f421c6f [FLINK-20675][checkpointing] Refactor interfaces to decline checkpoint with CheckpointException
No new revisions were added by this update.
Summary of changes:
.../state/api/runtime/SavepointEnvironment.java | 3 +-
.../runtime/checkpoint/CheckpointCoordinator.java | 15 +-
.../checkpoint/CheckpointFailureManager.java | 7 +-
.../flink/runtime/execution/Environment.java | 5 +-
.../runtime/jobgraph/tasks/AbstractInvokable.java | 4 +-
.../messages/checkpoint/DeclineCheckpoint.java | 31 +--
.../checkpoint/SerializedCheckpointException.java | 53 +++++
.../taskexecutor/rpc/RpcCheckpointResponder.java | 6 +-
.../runtime/taskmanager/CheckpointResponder.java | 8 +-
.../runtime/taskmanager/RuntimeEnvironment.java | 6 +-
.../checkpoint/CheckpointCoordinatorTest.java | 108 +++++++++--
.../CheckpointCoordinatorTestingUtils.java | 6 +
.../checkpoint/CheckpointFailureManagerTest.java | 3 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 20 +-
.../testutils/DummyCheckpointInvokable.java | 3 +-
.../operators/testutils/DummyEnvironment.java | 3 +-
.../operators/testutils/MockEnvironment.java | 3 +-
.../taskmanager/NoOpCheckpointResponder.java | 7 +-
.../runtime/taskmanager/TaskAsyncCallTest.java | 3 +-
.../taskmanager/TestCheckpointResponder.java | 11 +-
.../streaming/state/RocksDBAsyncSnapshotTest.java | 3 +-
.../runtime/tasks/AsyncCheckpointRunnable.java | 40 ++--
.../runtime/tasks/MultipleInputStreamTask.java | 4 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 5 +-
.../tasks/SubtaskCheckpointCoordinator.java | 5 +-
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 25 +--
.../checkpointing/CheckpointSequenceValidator.java | 3 +-
.../UnalignedControllerCancellationTest.java | 3 +-
.../io/checkpointing/UnalignedControllerTest.java | 5 +-
.../checkpointing/ValidatingCheckpointHandler.java | 4 +-
.../runtime/tasks/AsyncCheckpointRunnableTest.java | 34 +++-
.../runtime/tasks/LocalStateForwardingTest.java | 3 +-
.../runtime/tasks/StreamMockEnvironment.java | 6 +-
.../tasks/StreamTaskExecutionDecorationTest.java | 20 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 33 +---
.../tasks/SubtaskCheckpointCoordinatorTest.java | 12 +-
.../runtime/tasks/SynchronousCheckpointITCase.java | 3 +-
.../tasks/TaskCheckpointingBehaviourTest.java | 3 +-
.../tasks/TestSubtaskCheckpointCoordinator.java | 5 +-
.../CheckpointFailureManagerITCase.java | 214 +++++++++++++++++++++
40 files changed, 573 insertions(+), 162 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/messages/checkpoint/SerializedCheckpointException.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointFailureManagerITCase.java