This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b296738 [FLINK-23418][e2e] Increase the timeout to make kubernetes
application ha test more stable
add 7c90274 [FLINK-23460] Use a global feature flag in the
CheckpointBarrierHandler
add 8367dbd [FLINK-23460] Use a global feature flag in the
CheckpointCoordinator
add 8e63767 [FLINK-23460] Use global flag for enabling final checkpoints
in SubtaskCheckpointCoordinator
No new revisions were added by this update.
Summary of changes:
.../DefaultCheckpointPlanCalculator.java | 15 +++------
.../executiongraph/DefaultExecutionGraph.java | 9 ++++--
.../tasks/CheckpointCoordinatorConfiguration.java | 31 ++++++++++++++++---
.../CheckpointCoordinatorMasterHooksTest.java | 3 +-
.../CheckpointCoordinatorTestingUtils.java | 5 ++-
.../DefaultCheckpointPlanCalculatorTest.java | 4 +--
.../FailoverStrategyCheckpointCoordinatorTest.java | 3 +-
.../runtime/checkpoint/PendingCheckpointTest.java | 4 +--
.../environment/ExecutionCheckpointingOptions.java | 9 ++++++
.../environment/StreamExecutionEnvironment.java | 10 ++++++
.../flink/streaming/api/graph/StreamGraph.java | 10 ++++++
.../streaming/api/graph/StreamGraphGenerator.java | 4 +++
.../api/graph/StreamingJobGraphGenerator.java | 7 +++++
.../io/checkpointing/CheckpointBarrierHandler.java | 16 +++++-----
.../io/checkpointing/CheckpointBarrierTracker.java | 9 ++++--
.../io/checkpointing/InputProcessorUtil.java | 15 ++++++++-
.../SingleCheckpointBarrierHandler.java | 21 +++++++++----
.../flink/streaming/runtime/tasks/StreamTask.java | 23 +++++++++++---
.../tasks/SubtaskCheckpointCoordinator.java | 6 ----
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 21 ++++++-------
.../runtime/io/StreamTaskNetworkInputTest.java | 3 +-
.../AlignedCheckpointsMassiveRandomTest.java | 1 +
.../io/checkpointing/AlignedCheckpointsTest.java | 28 ++++++++++++-----
.../checkpointing/AlternatingCheckpointsTest.java | 1 -
.../CheckpointBarrierTrackerTest.java | 21 +------------
.../checkpointing/CheckpointedInputGateTest.java | 3 +-
.../checkpointing/TestBarrierHandlerFactory.java | 7 +++++
.../UnalignedCheckpointsCancellationTest.java | 1 +
.../io/checkpointing/UnalignedCheckpointsTest.java | 27 +++++++++++++---
.../MockSubtaskCheckpointCoordinatorBuilder.java | 8 +++++
...tStreamTaskChainedSourcesCheckpointingTest.java | 21 +++++++------
.../runtime/tasks/MultipleInputStreamTaskTest.java | 21 +++++++------
.../runtime/tasks/SourceStreamTaskTest.java | 15 ++++++---
.../tasks/StreamTaskFinalCheckpointsTest.java | 36 ++++++++++++----------
.../tasks/SubtaskCheckpointCoordinatorTest.java | 3 +-
.../tasks/TestSubtaskCheckpointCoordinator.java | 3 --
36 files changed, 275 insertions(+), 149 deletions(-)
