[hotfix] Auto-select actor system port in TestingCluster to prevent p…

…ort collisions
JacksonSha · Feb 17, 2016 · a4e8fcb · a4e8fcb
1 parent 06a42bf
commit a4e8fcb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingCluster.scala b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingCluster.scala
@@ -59,7 +59,7 @@ class TestingCluster(
   override def generateConfiguration(userConfig: Configuration): Configuration = {
     val cfg = new Configuration()
     cfg.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, "localhost")
-    cfg.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, NetUtils.getAvailablePort())
+    cfg.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, 0)
     cfg.setInteger(ConfigConstants.TASK_MANAGER_MEMORY_SIZE_KEY, 10)
     cfg.setInteger(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, -1)
 
@@ -145,7 +145,7 @@ class TestingCluster(
       system,
       hostname,
       Some(tmActorName),
-      Some(createLeaderRetrievalService),
+      Some(createLeaderRetrievalService()),
       numTaskManagers == 1,
       classOf[TestingTaskManager])
   }