You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/05/27 07:01:59 UTC
[flink] 04/04: [FLINK-17750][tests] Harden
YARNHighavailabilityITCase by increasing ZK session timeout to 20s
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 93b81a38efe4dce41c985cd93862d6cbf0c8d0c4
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Tue May 26 16:21:35 2020 +0200
[FLINK-17750][tests] Harden YARNHighavailabilityITCase by increasing ZK session timeout to 20s
In order to harden YARNHighAvailabilityITCase against ZK session timeouts, the timeout has been increased
from 1s to 20s. This increase also increases the runtime of YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint
slightly.
This closes #12347.
---
.../src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
index eba7140..6935ce3 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
@@ -274,7 +274,7 @@ public class YARNHighAvailabilityITCase extends YarnTestBase {
flinkConfiguration.setString(HighAvailabilityOptions.HA_MODE, "zookeeper");
flinkConfiguration.setString(HighAvailabilityOptions.HA_STORAGE_PATH, storageDir);
flinkConfiguration.setString(HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM, zkServer.getConnectString());
- flinkConfiguration.setInteger(HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT, 1000);
+ flinkConfiguration.setInteger(HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT, 20000);
flinkConfiguration.setString(RestartStrategyOptions.RESTART_STRATEGY, "fixed-delay");
flinkConfiguration.setInteger(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS, Integer.MAX_VALUE);