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

Posted to commits@flink.apache.org by ro...@apache.org on 2026/01/23 08:40:59 UTC

(flink) branch master updated (2860e9a723f -> 62566c4b445)

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 2860e9a723f [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading" documentation
     add 62566c4b445 [FLINK-38940] Start checkpointing when all tasks are running and job is running

No new revisions were added by this update.

Summary of changes:
 .../runtime/checkpoint/CheckpointCoordinator.java  |  19 ++-
 .../CheckpointCoordinatorDeActivator.java          |  30 ++--
 ...onTrackingCheckpointCoordinatorDeActivator.java | 104 ++++++++++++++
 .../executiongraph/DefaultExecutionGraph.java      |  22 ++-
 ...ackingCheckpointCoordinatorDeActivatorTest.java | 156 +++++++++++++++++++++
 .../checkpoint/TestingCheckpointStatsTracker.java} |  54 ++++---
 .../flink/runtime/jobgraph/JobGraphTestUtils.java  |  12 +-
 .../scheduler/adaptive/AdaptiveSchedulerTest.java  |  81 +++++++++++
 8 files changed, 423 insertions(+), 55 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ExecutionTrackingCheckpointCoordinatorDeActivator.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ExecutionTrackingCheckpointCoordinatorDeActivatorTest.java
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/checkpoint/NoOpCheckpointStatsTracker.java => test/java/org/apache/flink/runtime/checkpoint/TestingCheckpointStatsTracker.java} (64%)