This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 224822e8f7197d55d0e711f5efbf3cc43750e31e Author: Till Rohrmann <[email protected]> AuthorDate: Mon Jan 4 14:52:44 2021 +0100 [FLINK-20846] Remove CheckpointRecoveryFactory from ExecutionGraphBuilder.buildGraph --- .../flink/runtime/executiongraph/ExecutionGraphBuilder.java | 1 - .../org/apache/flink/runtime/scheduler/SchedulerBase.java | 1 - .../runtime/executiongraph/TestingExecutionGraphBuilder.java | 11 ----------- 3 files changed, 13 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java index bd0f526..d63b045 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java @@ -79,7 +79,6 @@ public class ExecutionGraphBuilder { Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, - CheckpointRecoveryFactory recoveryFactory, CompletedCheckpointStore completedCheckpointStore, CheckpointIDCounter checkpointIdCounter, Time rpcTimeout, diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java index 9dc60ea..15ac47a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java @@ -312,7 +312,6 @@ public abstract class SchedulerBase implements SchedulerNG { ioExecutor, slotProvider, userCodeLoader, - checkpointRecoveryFactory, completedCheckpointStore, checkpointIdCounter, rpcTimeout, diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingExecutionGraphBuilder.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingExecutionGraphBuilder.java index 57d48a2..0add2f6 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingExecutionGraphBuilder.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingExecutionGraphBuilder.java @@ -27,10 +27,8 @@ import org.apache.flink.runtime.akka.AkkaUtils; import org.apache.flink.runtime.blob.BlobWriter; import org.apache.flink.runtime.blob.VoidBlobWriter; import org.apache.flink.runtime.checkpoint.CheckpointIDCounter; -import org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory; import org.apache.flink.runtime.checkpoint.CompletedCheckpointStore; import org.apache.flink.runtime.checkpoint.StandaloneCheckpointIDCounter; -import org.apache.flink.runtime.checkpoint.StandaloneCheckpointRecoveryFactory; import org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore; import org.apache.flink.runtime.client.JobExecutionException; import org.apache.flink.runtime.io.network.partition.JobMasterPartitionTracker; @@ -74,8 +72,6 @@ public class TestingExecutionGraphBuilder { private Configuration jobMasterConfig = new Configuration(); private JobGraph jobGraph = new JobGraph(); private MetricGroup metricGroup = new UnregisteredMetricsGroup(); - private CheckpointRecoveryFactory checkpointRecoveryFactory = - new StandaloneCheckpointRecoveryFactory(); private CompletedCheckpointStore completedCheckpointStore = new StandaloneCompletedCheckpointStore(1); private CheckpointIDCounter checkpointIdCounter = new StandaloneCheckpointIDCounter(); @@ -146,12 +142,6 @@ public class TestingExecutionGraphBuilder { return this; } - public TestingExecutionGraphBuilder setCheckpointRecoveryFactory( - CheckpointRecoveryFactory checkpointRecoveryFactory) { - this.checkpointRecoveryFactory = checkpointRecoveryFactory; - return this; - } - public TestingExecutionGraphBuilder setCompletedCheckpointStore( CompletedCheckpointStore completedCheckpointStore) { this.completedCheckpointStore = completedCheckpointStore; @@ -184,7 +174,6 @@ public class TestingExecutionGraphBuilder { ioExecutor, slotProvider, userClassLoader, - checkpointRecoveryFactory, completedCheckpointStore, checkpointIdCounter, rpcTimeout,
