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 b9eee78 [FLINK-15841][core] Clarify that TimeWindow.intersect returns
true if there is no gap
add 099ba98 [FLINK-17342][checkpointing][hotfix] Synchronize access to
CheckpointCoordinator.pendingCheckpoints
add 842aaa6 [FLINK-17342][checkpointing][hotfix] Extract
CheckpointRequestDecider Pre-requsite refactoring to change decision logic
add 355184d [FLINK-17342][checkpointing] Enqueue savepoint requests in UC
mode
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 292 +++++++--------------
.../checkpoint/CheckpointFailureManager.java | 1 +
.../checkpoint/CheckpointFailureReason.java | 2 +
.../runtime/checkpoint/CheckpointProperties.java | 26 +-
.../checkpoint/CheckpointRequestDecider.java | 209 +++++++++++++++
.../flink/runtime/checkpoint/Checkpoints.java | 2 +-
.../checkpoint/CompletedCheckpointStore.java | 8 +
.../runtime/checkpoint/PendingCheckpoint.java | 6 +-
.../tasks/CheckpointCoordinatorConfiguration.java | 126 ++++++++-
.../flink/runtime/scheduler/SchedulerBase.java | 5 +-
.../CheckpointCoordinatorFailureTest.java | 4 +-
.../CheckpointCoordinatorMasterHooksTest.java | 6 +-
.../CheckpointCoordinatorRestoringTest.java | 25 +-
.../checkpoint/CheckpointCoordinatorTest.java | 233 ++++++++--------
.../CheckpointCoordinatorTestingUtils.java | 85 +-----
.../CheckpointCoordinatorTriggeringTest.java | 6 +-
.../checkpoint/CheckpointPropertiesTest.java | 4 +-
.../checkpoint/CheckpointRequestDeciderTest.java | 221 ++++++++++++++++
.../checkpoint/CheckpointStateRestoreTest.java | 3 +-
.../checkpoint/CheckpointStatsTrackerTest.java | 2 +-
.../FailoverStrategyCheckpointCoordinatorTest.java | 6 +-
.../runtime/checkpoint/PendingCheckpointTest.java | 6 +-
.../StandaloneCompletedCheckpointStoreTest.java | 2 +-
...oKeeperCompletedCheckpointStoreMockitoTest.java | 2 +-
...egionStrategyNGAbortPendingCheckpointsTest.java | 2 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 6 +-
.../runtime/scheduler/SchedulerTestingUtils.java | 2 +-
.../api/graph/StreamingJobGraphGenerator.java | 21 +-
28 files changed, 833 insertions(+), 480 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java
