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 e4c7d78 [FLINK-25134][test] Remove unused RetryRule from
KafkaConsumerTestBase
add 5bf49f1 [FLINK-24919][runtime] Getting vertex only under
synchronization
add b1c85d2 [refactor][runtime] CheckpointStatsTracker passed to
CheckpointCoordinator via constructor as not null parameter
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 54 ++++++++--------------
.../ExecutionAttemptMappingProvider.java | 39 +++++++++-------
.../executiongraph/DefaultExecutionGraph.java | 5 +-
.../CheckpointCoordinatorMasterHooksTest.java | 4 +-
.../checkpoint/CheckpointCoordinatorTest.java | 19 ++++----
.../CheckpointCoordinatorTestingUtils.java | 13 +++++-
.../FailoverStrategyCheckpointCoordinatorTest.java | 3 +-
7 files changed, 69 insertions(+), 68 deletions(-)
