This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d5b114f8156 [FLINK-28866] Use DDL instead of legacy method to register
the test source in JoinITCase
add 615e824195d [FLINK-32514][Runtime/Checkpointing] Support configuring
checkpointing interval during process backlog (#22931)
No new revisions were added by this update.
Summary of changes:
.../execution_checkpointing_configuration.html | 8 +-
.../source/hybrid/HybridSourceSplitEnumerator.java | 6 +
.../connector/source/SplitEnumeratorContext.java | 15 +
.../source/mocks/MockSplitEnumeratorContext.java | 3 +
.../ManuallyTriggeredScheduledExecutor.java | 4 +
.../runtime/checkpoint/CheckpointCoordinator.java | 128 +++++++-
.../checkpoint/CheckpointRequestDecider.java | 20 +-
.../tasks/CheckpointCoordinatorConfiguration.java | 22 ++
.../coordination/OperatorCoordinator.java | 5 +
.../coordination/OperatorCoordinatorHolder.java | 21 +-
.../RecreateOnResetOperatorCoordinator.java | 7 +
.../DefaultOperatorCoordinatorHandler.java | 10 +-
.../flink/runtime/scheduler/SchedulerBase.java | 16 +
.../runtime/scheduler/VertexEndOfDataListener.java | 7 +
.../adaptive/StateWithExecutionGraph.java | 16 +
.../coordinator/SourceCoordinatorContext.java | 12 +
.../checkpoint/CheckpointCoordinatorTest.java | 50 ++-
.../CheckpointCoordinatorTriggeringTest.java | 24 +-
.../checkpoint/CheckpointRequestDeciderTest.java | 4 +-
.../FailoverStrategyCheckpointCoordinatorTest.java | 3 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 2 +-
.../MockOperatorCoordinatorContext.java | 6 +
.../OperatorCoordinatorHolderTest.java | 2 +-
.../api/environment/CheckpointConfig.java | 66 ++++
.../environment/ExecutionCheckpointingOptions.java | 29 +-
.../api/graph/StreamingJobGraphGenerator.java | 2 +
.../reader/TestingSplitEnumeratorContext.java | 5 +
.../ManuallyTriggeredScheduledExecutorService.java | 40 ++-
.../OperatorEventSendingCheckpointITCase.java | 123 +-------
.../CheckpointIntervalDuringBacklogITCase.java | 343 +++++++++++++++++++++
.../NumberSequenceSourceWithWaitForCheckpoint.java | 140 +++++++++
31 files changed, 953 insertions(+), 186 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointIntervalDuringBacklogITCase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/util/NumberSequenceSourceWithWaitForCheckpoint.java
