Skip to content

Commit

Permalink
[hotfix] Remove RecoveryMode from JobMaster
Browse files Browse the repository at this point in the history
The recovery mode is not used any more by the latest CheckpointCoordinator.

All difference in recovery logic between high-availability and non-high-availability
is encapsulated in the HighAvailabilityServices.
  • Loading branch information
StephanEwen committed Dec 23, 2016
1 parent b65b400 commit 633fd3e
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.highavailability.HighAvailabilityServices;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobmanager.RecoveryMode;
import org.apache.flink.runtime.leaderelection.LeaderContender;
import org.apache.flink.runtime.leaderelection.LeaderElectionService;
import org.apache.flink.runtime.messages.Acknowledge;
Expand Down Expand Up @@ -57,7 +56,6 @@ public class JobMaster extends RpcEndpoint<JobMasterGateway> {

/** Configuration of the job */
private final Configuration configuration;
private final RecoveryMode recoveryMode;

/** Service to contend for and retrieve the leadership of JM and RM */
private final HighAvailabilityServices highAvailabilityServices;
Expand Down Expand Up @@ -86,7 +84,6 @@ public JobMaster(
this.jobID = Preconditions.checkNotNull(jobGraph.getJobID());

this.configuration = Preconditions.checkNotNull(configuration);
this.recoveryMode = RecoveryMode.fromConfig(configuration);

this.highAvailabilityServices = Preconditions.checkNotNull(highAvailabilityService);
}
Expand Down

0 comments on commit 633fd3e

Please sign in to comment.