You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2021/01/25 16:57:11 UTC
[flink] 10/11: [hotfix][runtime] Remove unused
SchedulerBase.checkpointRecoveryFactory
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 60fb0f5c6e4e23759541a531e034f27f496e93b7
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Thu Jan 14 17:51:17 2021 +0100
[hotfix][runtime] Remove unused SchedulerBase.checkpointRecoveryFactory
---
.../main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 e18f03f..efe665e 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
@@ -204,11 +204,11 @@ public abstract class SchedulerBase implements SchedulerNG {
jobGraph,
jobMasterConfiguration,
userCodeLoader,
- checkpointRecoveryFactory,
+ checkNotNull(checkpointRecoveryFactory),
log);
this.checkpointIdCounter =
SchedulerUtils.createCheckpointIDCounterIfCheckpointingIsEnabled(
- jobGraph, checkpointRecoveryFactory);
+ jobGraph, checkNotNull(checkpointRecoveryFactory));
this.executionGraph =
createAndRestoreExecutionGraph(