[flink] branch release-1.15 updated: [FLINK-30539][tests] Removes timeout from YARNSessionCapacitySchedulerITCase

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mapohl pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new 45c0503295f [FLINK-30539][tests] Removes timeout from YARNSessionCapacitySchedulerITCase
45c0503295f is described below

commit 45c0503295fdf0874998b090dae2bb6a583d3b46
Author: Matthias Pohl <ma...@aiven.io>
AuthorDate: Mon Jan 2 13:57:23 2023 +0100

    [FLINK-30539][tests] Removes timeout from YARNSessionCapacitySchedulerITCase
    
    This change should improve our abilities to investigate the cause because the
    timeout will now be handled by our watchdog process which prints the thread
    dump at the end.
    
    Signed-off-by: Matthias Pohl <ma...@aiven.io>
---
 .../org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java
index 2089b5cbaa4..3b9694dfac1 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java
@@ -523,7 +523,7 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase {
     }
 
     /** Test a fire-and-forget job submission to a YARN cluster. */
-    @Test(timeout = 60000)
+    @Test
     public void testDetachedPerJobYarnCluster() throws Exception {
         runTest(
                 () -> {
@@ -538,7 +538,7 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase {
     }
 
     /** Test a fire-and-forget job submission to a YARN cluster. */
-    @Test(timeout = 60000)
+    @Test
     public void testDetachedPerJobYarnClusterWithStreamingJob() throws Exception {
         runTest(
                 () -> {