[FLINK-30629][test] Set CLIENT_ALIVENESS_CHECK_DURATION to clientHear…

…tbeatInterval for ClientHeartbeatTest#testJobCancelledIfClientHeartbeatTimeout. This closes apache#21916
jonchase · Feb 15, 2023 · bf0ad52 · bf0ad52
1 parent 00e1ef3
commit bf0ad52
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-clients/src/test/java/org/apache/flink/client/ClientHeartbeatTest.java b/flink-clients/src/test/java/org/apache/flink/client/ClientHeartbeatTest.java
@@ -94,7 +94,7 @@ private Configuration createConfiguration(boolean shutdownOnAttachedExit) {
         Configuration configuration = new Configuration();
         configuration.set(
                 Dispatcher.CLIENT_ALIVENESS_CHECK_DURATION,
-                Duration.ofMillis(clientHeartbeatTimeout));
+                Duration.ofMillis(clientHeartbeatInterval));
         if (shutdownOnAttachedExit) {
             configuration.setBoolean(DeploymentOptions.ATTACHED, true);
             configuration.setBoolean(DeploymentOptions.SHUTDOWN_IF_ATTACHED, true);