This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from da75518e7cd [FLINK-39108][tests] Disable
CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog
new 259a6a705aa [hotfix][tests] Close OutputWriter in
SourceOperatorStreamTaskTest
new 7c90b9e4eb6 [FLINK-38939][runtime] Pause Sources until the first
checkpoint barrier is received
new c0ada39aafa [hotfix][runtime] Try to get last checkpoint on recovery
regardless of checkpointing interval
new b2b044dc668 [hotfix][runtime] Move checkpointing configuration code to
CheckpointCoordinatorConfiguration
new 1175aa908dd [FLINK-38939] Minimize checkpoint trigger delay if sources
are waiting for a checkpoint
new c06640f9331 [hotfix][tests] Increase min pause between checkpoints in
migration tests
new ae0c1e6a05f [hotfix][tests] De-duplicate operator IDs in
RestoreUpgradedJobITCase
The 7 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:
.../generated/checkpointing_configuration.html | 6 +
.../flink/configuration/CheckpointingOptions.java | 12 ++
.../runtime/checkpoint/CheckpointCoordinator.java | 32 ++--
...ctivatedCheckpointCompletedCheckpointStore.java | 3 +-
.../tasks/CheckpointCoordinatorConfiguration.java | 48 +++++-
.../scheduler/adaptive/AdaptiveScheduler.java | 6 +-
.../api/environment/CheckpointConfig.java | 13 ++
.../flink/streaming/api/graph/StreamGraph.java | 2 +
.../api/graph/StreamingJobGraphGenerator.java | 13 ++
.../streaming/api/operators/SourceOperator.java | 34 +++-
.../api/operators/SourceOperatorFactory.java | 17 +-
.../checkpoint/CheckpointCoordinatorTest.java | 52 ++++++
.../adaptive/AdaptiveSchedulerTestBase.java | 8 +-
.../scheduler/adaptive/LocalRecoveryTest.java | 5 +-
.../api/operators/SourceOperatorAlignmentTest.java | 6 +-
.../SourceOperatorSplitWatermarkAlignmentTest.java | 2 +
.../api/operators/SourceOperatorTest.java | 190 +++++++++++++++------
.../api/operators/SourceOperatorTestContext.java | 65 ++++++-
.../operators/source/TestingSourceOperator.java | 9 +-
.../apache/flink/streaming/util/MockOutput.java | 4 +
.../tasks/SourceOperatorStreamTaskTest.java | 5 +-
.../tasks/StreamTaskMailboxTestHarness.java | 4 +
.../OperatorEventSendingCheckpointITCase.java | 22 ++-
.../CheckpointIntervalDuringBacklogITCase.java | 10 +-
.../checkpointing/RestoreUpgradedJobITCase.java | 19 ++-
.../UnalignedCheckpointFailureHandlingITCase.java | 3 +-
.../restore/AbstractOperatorRestoreTestBase.java | 3 +
.../NumberSequenceSourceWithWaitForCheckpoint.java | 20 ++-
28 files changed, 488 insertions(+), 125 deletions(-)
