[FLINK-10983][queryable state] Increase port range for NonHAQueryable…

…StateFsBackendITCase This closes apache#7159
laubersder · Nov 22, 2018 · 7854e84 · 7854e84
1 parent cbf5f0c
commit 7854e84
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java b/...test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java
@@ -44,6 +44,7 @@ public class NonHAQueryableStateFsBackendITCase extends AbstractQueryableStateTe
 	// we always use all TaskManagers so that the JM oracle is always properly re-registered
 	private static final int NUM_TMS = 2;
 	private static final int NUM_SLOTS_PER_TM = 2;
+	private static final int NUM_PORT_COUNT = 100;
 
 	private static final int QS_PROXY_PORT_RANGE_START = 9084;
 	private static final int QS_SERVER_PORT_RANGE_START = 9089;
@@ -86,10 +87,10 @@ private static Configuration getConfig() {
 		config.setInteger(QueryableStateOptions.SERVER_NETWORK_THREADS, 1);
 		config.setString(
 			QueryableStateOptions.PROXY_PORT_RANGE,
-			QS_PROXY_PORT_RANGE_START + "-" + (QS_PROXY_PORT_RANGE_START + NUM_TMS));
+			QS_PROXY_PORT_RANGE_START + "-" + (QS_PROXY_PORT_RANGE_START + NUM_PORT_COUNT));
 		config.setString(
 			QueryableStateOptions.SERVER_PORT_RANGE,
-			QS_SERVER_PORT_RANGE_START + "-" + (QS_SERVER_PORT_RANGE_START + NUM_TMS));
+			QS_SERVER_PORT_RANGE_START + "-" + (QS_SERVER_PORT_RANGE_START + NUM_PORT_COUNT));
 		config.setBoolean(WebOptions.SUBMIT_ENABLE, false);
 		return config;
 	}