You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/11/21 14:20:39 UTC
[flink] branch master updated: [FLINK-30085][yarn][tests] Lower client timeouts
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 0634d0cc0a4 [FLINK-30085][yarn][tests] Lower client timeouts
0634d0cc0a4 is described below
commit 0634d0cc0a401d268cc1b3788c8ee63a91ff33a6
Author: Gabor Somogyi <ga...@apple.com>
AuthorDate: Mon Nov 21 15:20:31 2022 +0100
[FLINK-30085][yarn][tests] Lower client timeouts
---
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
index 640ff9f958c..1cd27df554a 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
@@ -225,6 +225,9 @@ public abstract class YarnTestBase {
YARN_CONFIGURATION.setFloat(
YarnConfiguration.NM_MAX_PER_DISK_UTILIZATION_PERCENTAGE, 99.0F);
YARN_CONFIGURATION.set(YarnConfiguration.YARN_APPLICATION_CLASSPATH, getYarnClasspath());
+ YARN_CONFIGURATION.setInt(
+ YarnConfiguration.RESOURCEMANAGER_CONNECT_RETRY_INTERVAL_MS, 1000);
+ YARN_CONFIGURATION.setInt(YarnConfiguration.RESOURCEMANAGER_CONNECT_MAX_WAIT_MS, 5000);
}
/**