You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by dw...@apache.org on 2021/12/02 08:33:44 UTC

[flink] branch master updated (e4c7d78 -> b1c85d2)

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(-)