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


The following commit(s) were added to refs/heads/master by this push:
     new 9b4fc49  [FLINK-22819][yarn] Remove 
'yarn.am.liveness-monitor.expiry-interval-ms' override for tests.
9b4fc49 is described below

commit 9b4fc49a44920b6d94b8e69a98f3f725e6b63c22
Author: David Moravek <d...@apache.org>
AuthorDate: Wed Jul 7 15:27:07 2021 +0200

    [FLINK-22819][yarn] Remove 'yarn.am.liveness-monitor.expiry-interval-ms' 
override for tests.
    
    This is an interval between AM container allocation and actually running RM 
Client inside this container,
    which can take longer in resource limited environment such as CI. If 
heartbeats between AM and RM don't
    work and a test relies on this, then it will fail a bit later because the 
default value is 5 minutes.
    
    This closes #16413.
---
 .../src/test/java/org/apache/flink/yarn/YarnTestBase.java             | 4 ----
 1 file changed, 4 deletions(-)

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 da334c9..b4dc3d3 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
@@ -217,12 +217,8 @@ public abstract class YarnTestBase extends TestLogger {
         YARN_CONFIGURATION.setInt(
                 YarnConfiguration.NM_VCORES, 666); // memory is overwritten in 
the MiniYARNCluster.
         // so we have to change the number of cores for testing.
-        YARN_CONFIGURATION.setInt(
-                YarnConfiguration.RM_AM_EXPIRY_INTERVAL_MS,
-                20000); // 20 seconds expiry (to ensure we properly heartbeat 
with YARN).
         YARN_CONFIGURATION.setFloat(
                 YarnConfiguration.NM_MAX_PER_DISK_UTILIZATION_PERCENTAGE, 
99.0F);
-
         YARN_CONFIGURATION.set(YarnConfiguration.YARN_APPLICATION_CLASSPATH, 
getYarnClasspath());
     }
 

Reply via email to