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