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 af692899350b75b4bfc25e1460c8f924507cda84 Author: Till Rohrmann <[email protected]> AuthorDate: Fri Feb 22 12:23:12 2019 +0100 [FLINK-11718] Remove start override from JobMaster --- .../main/java/org/apache/flink/runtime/jobmaster/JobMaster.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java index 50c391e..afd39e0 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java @@ -309,11 +309,6 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast // Lifecycle management //---------------------------------------------------------------------------------------------- - @Override - public void start() { - throw new UnsupportedOperationException("Should never call start() without leader ID"); - } - /** * Start the rpc service and begin to run the job. * @@ -322,7 +317,7 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast */ public CompletableFuture<Acknowledge> start(final JobMasterId newJobMasterId) throws Exception { // make sure we receive RPC and async calls - super.start(); + start(); return callAsyncWithoutFencing(() -> startJobExecution(newJobMasterId), RpcUtils.INF_TIMEOUT); }
