diff --git a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index 19416032698..2d80815b5a3 100644 --- a/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -64,6 +64,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index 19416032698..2d80815b5a3 100644 --- a/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -64,6 +64,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index 9eb36efe932..236fde78a55 100644 --- a/client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -73,6 +73,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index be70f0f4ad7..3ff73db5a42 100644 --- a/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -73,6 +73,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index be70f0f4ad7..3ff73db5a42 100644 --- a/client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -73,6 +73,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index 451f6001bec..b1a3fadb941 100644 --- a/client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -73,6 +73,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); } diff --git a/client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java b/client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java index 4b3f81aa480..03718df18e1 100644 --- a/client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java +++ b/client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java @@ -76,6 +76,7 @@ public void setUp() { int startPort = Utils$.MODULE$.selectRandomInt(1024, 65535); configuration.setInteger("celeborn.master.port", startPort); configuration.setString("celeborn.master.endpoints", "localhost:" + startPort); + configuration.setString("celeborn.client.application.heartbeatInterval", "30s"); remoteShuffleMaster = createShuffleMaster(configuration); }