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 <[email protected]> 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);
