This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 58d749a [minor] Update IDE setup guide, to apply Save Actions only to
Java files
new 1bbb8b6 [FLINK-20846] Factor out CompletedCheckpointStore and
CheckpointIDCounter creation in ExecutionGraphBuilder.buildGraph
new fa49e84 [FLINK-20846] Move CheckpointIDCounter creation out of
ExecutionGraphBuilder
new 10f9f62 [hotfix][tests] Replace explicit
ExecutionGraphBuilder.buildGraph calls with TestingExecutionGraphBuilder
new 38bcfd9 [hotfix] Remove unused ExecutionGraphBuilder.buildGraph method
new 01e4745 [FLINK-20846] Move CompletedCheckpointStore creation out of
ExecutionGraphBuilder.buildGraph
new 224822e [FLINK-20846] Remove CheckpointRecoveryFactory from
ExecutionGraphBuilder.buildGraph
new 1538eb2 [FLINK-20846] Move checkpoint service shut down out of
CheckpointCoordinator
new 936489d [hotfix] Remove unused jobStatus parameter from
CheckpointCoordinator.shutdown()
new 18feec2 [hotfix] Factor CompletedCheckpointStore and
CheckpointIDCounter factories out
new 5351203 [hotfix][tests] Remove ProgrammedSlotProvider
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 11 +-
...ctivatedCheckpointCompletedCheckpointStore.java | 76 ++++++++++
...er.java => DeactivatedCheckpointIDCounter.java} | 37 ++---
.../runtime/executiongraph/ExecutionGraph.java | 7 +-
.../executiongraph/ExecutionGraphBuilder.java | 134 ++++-------------
.../flink/runtime/scheduler/SchedulerBase.java | 71 ++++++++-
.../flink/runtime/scheduler/SchedulerUtils.java | 115 +++++++++++++++
.../CheckpointCoordinatorMasterHooksTest.java | 3 +-
.../CheckpointCoordinatorRestoringTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorTest.java | 48 +++---
.../CheckpointCoordinatorTriggeringTest.java | 8 +-
.../CheckpointSettingsSerializableTest.java | 32 +---
.../ExecutionGraphDeploymentTest.java | 50 +------
.../ExecutionGraphRescalingTest.java | 83 +----------
.../ExecutionVertexLocalityTest.java | 28 +---
.../executiongraph/ProgrammedSlotProvider.java | 163 ---------------------
.../TestingExecutionGraphBuilder.java | 29 ++--
.../runtime/scheduler/SchedulerUtilsTest.java | 55 +++++++
18 files changed, 430 insertions(+), 522 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DeactivatedCheckpointCompletedCheckpointStore.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/{StandaloneCheckpointIDCounter.java
=> DeactivatedCheckpointIDCounter.java} (58%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerUtils.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ProgrammedSlotProvider.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerUtilsTest.java
