This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0e9ddbcbfae556860c0c5323e616cc82f55efe6a 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);
