[FLINK-10757] [tests] Avoid port conflicts in AbstractTaskManagerProc…

…essFailureRecoveryTest This closes apache#6998.
deepfield · Nov 2, 2018 · d3696e5 · d3696e5
1 parent d20b1ea
commit d3696e5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...st/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java b/...st/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
@@ -24,6 +24,7 @@
 import org.apache.flink.configuration.HeartbeatManagerOptions;
 import org.apache.flink.configuration.HighAvailabilityOptions;
 import org.apache.flink.configuration.JobManagerOptions;
+import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.configuration.TaskManagerOptions;
 import org.apache.flink.runtime.clusterframework.types.ResourceID;
 import org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint;
@@ -98,6 +99,7 @@ public void testTaskManagerProcessFailure() throws Exception {
  Configuration config = new Configuration();
  config.setString(AkkaOptions.ASK_TIMEOUT, "100 s");
  config.setString(JobManagerOptions.ADDRESS, "localhost");
+ config.setInteger(RestOptions.PORT, 0);
  config.setLong(HeartbeatManagerOptions.HEARTBEAT_INTERVAL, 500L);
  config.setLong(HeartbeatManagerOptions.HEARTBEAT_TIMEOUT, 10000L);
  config.setString(HighAvailabilityOptions.HA_MODE, "zookeeper");