This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 77dce77 [FLINK-16587][checkpointing] Fix abortion of
ChannelStateWriter and add test/IT cases for unaligned checkpoint.
add d3fa2e5 Revert "[FLINK-16945][checkpointing] Execute
CheckpointFailureManager.FailJobCallback directly in main thread executor"
add cfe5a27 Revert "[hotfix] Make the checkpoint resuming e2e case pass
by increasing the retained checkpoints number"
add 5d5a29b Revert "[FLINK-14971][checkpointing] Remove lock of
PendingCheckpoint and introduce IO lock for PendingCheckpoint"
add 214896a Revert "[FLINK-14971][checkpointing] Remove coordinator-wide
lock of CheckpointCoordinator"
add 6adbe94 Revert "[FLINK-14971][checkpointing] Make
CompletedCheckpointStore thread-safe to avoid synchronization outside"
add e217a8c Revert "[hotfix] Harden ResumeCheckpointManuallyITCase"
add 2813be7 Revert "[FLINK-14971][checkpointing] Introduce main thread
executor in CheckpointCoordinator to execute all non-IO operations instead of
the timer thread"
add ffa4475 Revert "[FLINK-14971][checkpointing] Handle ack/declined
message of checkpoint"
No new revisions were added by this update.
Summary of changes:
.../test_resume_externalized_checkpoints.sh | 2 -
.../test-scripts/test_resume_savepoint.sh | 2 -
.../runtime/checkpoint/CheckpointCoordinator.java | 733 +++++++++++----------
.../checkpoint/CompletedCheckpointStore.java | 4 -
.../runtime/checkpoint/PendingCheckpoint.java | 325 +++++----
.../StandaloneCompletedCheckpointStore.java | 51 +-
.../ZooKeeperCompletedCheckpointStore.java | 195 +++---
.../runtime/executiongraph/ExecutionGraph.java | 9 +-
.../flink/runtime/scheduler/SchedulerBase.java | 24 +-
.../CheckpointCoordinatorFailureTest.java | 17 +-
.../CheckpointCoordinatorMasterHooksTest.java | 14 +-
.../CheckpointCoordinatorRestoringTest.java | 34 +-
.../checkpoint/CheckpointCoordinatorTest.java | 184 +++---
.../CheckpointCoordinatorTestingUtils.java | 16 +-
.../CheckpointCoordinatorTriggeringTest.java | 74 +--
.../checkpoint/CheckpointStateRestoreTest.java | 8 +-
.../ExecutionGraphCheckpointCoordinatorTest.java | 122 +---
.../FailoverStrategyCheckpointCoordinatorTest.java | 26 +-
.../runtime/checkpoint/PendingCheckpointTest.java | 212 +-----
.../ZooKeeperCompletedCheckpointStoreITCase.java | 2 -
...egionStrategyNGAbortPendingCheckpointsTest.java | 10 +-
.../executiongraph/ArchivedExecutionGraphTest.java | 4 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 45 +-
.../ResumeCheckpointManuallyITCase.java | 28 +-
24 files changed, 846 insertions(+), 1295 deletions(-)
