Skip to content

Commit 72cefb5

Browse files
committed
New REST port for embedded flink
1 parent c2654f8 commit 72cefb5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/test/embedded/flink/EmbeddedFlinkClusterForTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
public class EmbeddedFlinkClusterForTests {
1010

1111
static MiniClusterWithClientResource flinkCluster = null;
12-
static int REST_PORT = getFromEnvOrDefault("REST_PORT", 8081);
12+
static int REST_PORT = getFromEnvOrDefault("REST_PORT", 9091);
1313
static int NUM_TASK_SLOTS = getFromEnvOrDefault("NUM_TASK_SLOTS", 2);
1414
static int NUM_TASK_SLOTS_PER_TASK = getFromEnvOrDefault("NUM_TASK_SLOTS_PER_TASK" , 2);
1515
static int NUM_TASK_MANAGERS = getFromEnvOrDefault("NUM_TASK_MANAGERS",3);

0 commit comments

Comments
 (0)