[hotfix] fix ResourceManagerGateway

naraee · Dec 23, 2016 · 0370888 · 0370888
1 parent b08e257
commit 0370888
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...untime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java b/...untime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java
@@ -27,7 +27,6 @@
 import org.apache.flink.runtime.jobmaster.JobMaster;
 import org.apache.flink.runtime.registration.RegistrationResponse;
 
-import org.apache.flink.runtime.registration.RegistrationResponse;
 import java.util.UUID;
 
 /**
@@ -39,13 +38,15 @@ public interface ResourceManagerGateway extends RpcGateway {
 	 * Register a {@link JobMaster} at the resource manager.
 	 *
 	 * @param resourceManagerLeaderId The fencing token for the ResourceManager leader
+	 * @param jobMasterLeaderId The fencing token for the JobMaster leader
 	 * @param jobMasterAddress        The address of the JobMaster that registers
 	 * @param jobID                   The Job ID of the JobMaster that registers
 	 * @param timeout                 Timeout for the future to complete
 	 * @return Future registration response
 	 */
 	Future<RegistrationResponse> registerJobMaster(
 		UUID resourceManagerLeaderId,
+		UUID jobMasterLeaderId,
 		String jobMasterAddress,
 		JobID jobID,
 		@RpcTimeout Time timeout);