You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2021/02/06 02:55:15 UTC
[flink] branch master updated (f63b9ad -> 2d40387)

This is an automated email from the ASF dual-hosted git repository.

guoweima pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from f63b9ad  [hotfix] Fix RocksDB resource handling in RocksKeyGroupsRocksSingleStateIteratorTest
     add 2d40387  [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

No new revisions were added by this update.

Summary of changes:
 .../jobmanager/JMXJobManagerMetricTest.java        |   5 -
 .../runtime/checkpoint/CheckpointCoordinator.java  | 160 +++++----------------
 .../flink/runtime/checkpoint/CheckpointPlan.java   |  69 +++++++++
 .../checkpoint/CheckpointPlanCalculator.java       | 126 ++++++++++++++++
 .../ExecutionAttemptMappingProvider.java           |  77 ++++++++++
 .../runtime/checkpoint/PendingCheckpoint.java      |  15 +-
 .../runtime/executiongraph/ExecutionGraph.java     |  60 ++++----
 .../executiongraph/ExecutionGraphBuilder.java      |  31 ----
 .../jobgraph/tasks/JobCheckpointingSettings.java   |  50 +------
 .../CheckpointCoordinatorMasterHooksTest.java      |   9 +-
 .../CheckpointCoordinatorTestingUtils.java         |  13 +-
 .../CheckpointSettingsSerializableTest.java        |   5 -
 .../checkpoint/CheckpointStatsTrackerTest.java     |   4 -
 .../ExecutionGraphCheckpointCoordinatorTest.java   |   7 +-
 .../FailoverStrategyCheckpointCoordinatorTest.java |  15 +-
 .../runtime/checkpoint/PendingCheckpointTest.java  |   5 +-
 .../executiongraph/ArchivedExecutionGraphTest.java |   8 +-
 .../ExecutionGraphDeploymentTest.java              |   3 -
 .../flink/runtime/jobgraph/JobGraphTest.java       |   8 +-
 .../tasks/JobCheckpointingSettingsTest.java        |   9 --
 .../flink/runtime/jobmaster/JobMasterTest.java     |   7 +-
 .../CoordinatorEventsExactlyOnceITCase.java        |   8 +-
 .../runtime/scheduler/SchedulerTestingUtils.java   |  20 +--
 .../api/graph/StreamingJobGraphGenerator.java      |  25 ----
 .../jobmaster/JobMasterStopWithSavepointIT.java    |   3 -
 .../jobmaster/JobMasterTriggerSavepointITCase.java |   3 -
 26 files changed, 386 insertions(+), 359 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointPlan.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointPlanCalculator.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ExecutionAttemptMappingProvider.java