From 0a44c3aa5725221c290c0bf00702e086e9d5841a Mon Sep 17 00:00:00 2001
From: Roman Khachatryan <khachatryan.roman@gmail.com>
Date: Thu, 14 Jan 2021 17:51:17 +0100
Subject: [PATCH] [hotfix][runtime] Remove unused
 SchedulerBase.checkpointRecoveryFactory

---
 .../org/apache/flink/runtime/scheduler/SchedulerBase.java  | 7 ++-----
 1 file changed, 2 insertions(+), 5 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 8bd1a015f02ece..bdcffc72de9d0a 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
@@ -152,8 +152,6 @@ public abstract class SchedulerBase implements SchedulerNG {
 
     private final ClassLoader userCodeLoader;
 
-    private final CheckpointRecoveryFactory checkpointRecoveryFactory;
-
     private final CompletedCheckpointStore completedCheckpointStore;
 
     private final CheckpointsCleaner checkpointsCleaner;
@@ -201,7 +199,6 @@ public SchedulerBase(
         this.jobMasterConfiguration = checkNotNull(jobMasterConfiguration);
         this.futureExecutor = checkNotNull(futureExecutor);
         this.userCodeLoader = checkNotNull(userCodeLoader);
-        this.checkpointRecoveryFactory = checkNotNull(checkpointRecoveryFactory);
         this.rpcTimeout = checkNotNull(rpcTimeout);
 
         this.blobWriter = checkNotNull(blobWriter);
@@ -214,11 +211,11 @@ public SchedulerBase(
                         jobGraph,
                         jobMasterConfiguration,
                         userCodeLoader,
-                        checkpointRecoveryFactory,
+                        checkNotNull(checkpointRecoveryFactory),
                         log);
         this.checkpointIdCounter =
                 SchedulerUtils.createCheckpointIDCounterIfCheckpointingIsEnabled(
-                        jobGraph, checkpointRecoveryFactory);
+                        jobGraph, checkNotNull(checkpointRecoveryFactory));
 
         this.executionGraph =
                 createAndRestoreExecutionGraph(