[hotfix] Remove unused method MiniCluster#waitUntilTaskManagerRegistrationsComplete
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1897e238 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1897e238 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1897e238 Branch: refs/heads/master Commit: 1897e238eb9556e6c3e1ffd1169109ec9ed8f217 Parents: c131546 Author: Till Rohrmann <[email protected]> Authored: Thu Feb 15 17:58:35 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Fri Feb 23 18:22:07 2018 +0100 ---------------------------------------------------------------------- .../flink/runtime/minicluster/MiniCluster.java | 47 -------------------- 1 file changed, 47 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/1897e238/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java index 3f019f4..c98387d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java @@ -42,7 +42,6 @@ import org.apache.flink.runtime.highavailability.HighAvailabilityServices; import org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils; import org.apache.flink.runtime.jobgraph.JobGraph; import org.apache.flink.runtime.jobmaster.JobResult; -import org.apache.flink.runtime.leaderelection.LeaderAddressAndId; import org.apache.flink.runtime.leaderretrieval.LeaderRetrievalException; import org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService; import org.apache.flink.runtime.messages.Acknowledge; @@ -508,52 +507,6 @@ public class MiniCluster implements JobExecutorService, AutoCloseableAsync { } } - public void waitUntilTaskManagerRegistrationsComplete() throws Exception { - LeaderRetrievalService rmMasterListener = null; - CompletableFuture<LeaderAddressAndId> addressAndIdFuture; - - try { - synchronized (lock) { - checkState(running, "FlinkMiniCluster is not running"); - - OneTimeLeaderListenerFuture listenerFuture = new OneTimeLeaderListenerFuture(); - rmMasterListener = haServices.getResourceManagerLeaderRetriever(); - rmMasterListener.start(listenerFuture); - addressAndIdFuture = listenerFuture.future(); - } - - final LeaderAddressAndId addressAndId = addressAndIdFuture.get(); - - final ResourceManagerGateway resourceManager = commonRpcService - .connect( - addressAndId.leaderAddress(), - new ResourceManagerId(addressAndId.leaderId()), - ResourceManagerGateway.class) - .get(); - - final int numTaskManagersToWaitFor = taskManagers.length; - - // poll and wait until enough TaskManagers are available - while (true) { - int numTaskManagersAvailable = resourceManager.getNumberOfRegisteredTaskManagers().get(); - - if (numTaskManagersAvailable >= numTaskManagersToWaitFor) { - break; - } - Thread.sleep(2); - } - } - finally { - try { - if (rmMasterListener != null) { - rmMasterListener.stop(); - } - } catch (Exception e) { - LOG.warn("Error shutting down leader listener for ResourceManager"); - } - } - } - // ------------------------------------------------------------------------ // running jobs // ------------------------------------------------------------------------
