You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/02/02 12:31:31 UTC

[flink] branch master updated: Revert "Add e2e_uploading_watchdog to all tasks." and "[temp] Added infinite test."

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

arvid 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 0a27d11  Revert "Add e2e_uploading_watchdog to all tasks." and "[temp] Added infinite test."
0a27d11 is described below

commit 0a27d11a11ffd73a4805c222871248647e587840
Author: Arvid Heise <ar...@ververica.com>
AuthorDate: Tue Feb 2 13:29:16 2021 +0100

    Revert "Add e2e_uploading_watchdog to all tasks." and "[temp] Added infinite test."
    
    This reverts commit 4227490d
    
    Revert
    
    This reverts commit 94ecb916
---
 .../flink/runtime/io/network/api/CheckpointBarrierTest.java  | 12 ------------
 tools/azure-pipelines/jobs-template.yml                      |  2 +-
 2 files changed, 1 insertion(+), 13 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/CheckpointBarrierTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/CheckpointBarrierTest.java
index 5971e21..70de345 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/CheckpointBarrierTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/CheckpointBarrierTest.java
@@ -23,8 +23,6 @@ import org.apache.flink.core.memory.DataOutputSerializer;
 import org.apache.flink.runtime.checkpoint.CheckpointOptions;
 
 import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import static org.junit.Assert.fail;
 
@@ -57,14 +55,4 @@ public class CheckpointBarrierTest {
             // expected
         }
     }
-
-    private static final Logger LOG = LoggerFactory.getLogger(CheckpointBarrierTest.class);
-
-    @Test
-    public void testStall() throws InterruptedException {
-        while (true) {
-            Thread.sleep(60000);
-            LOG.info("Still working");
-        }
-    }
 }
diff --git a/tools/azure-pipelines/jobs-template.yml b/tools/azure-pipelines/jobs-template.yml
index 454faa3..5a8e219 100644
--- a/tools/azure-pipelines/jobs-template.yml
+++ b/tools/azure-pipelines/jobs-template.yml
@@ -144,7 +144,7 @@ jobs:
       source ./tools/azure-pipelines/debug_files_utils.sh
       prepare_debug_files $(module)
       
-      ${{parameters.environment}} ./tools/azure-pipelines/e2e_uploading_watchdog.sh ./tools/ci/test_controller.sh $(module) ; TEST_EXIT_CODE=$?
+      ${{parameters.environment}} ./tools/ci/test_controller.sh $(module) ; TEST_EXIT_CODE=$?
     
       compress_debug_files
       exit $TEST_EXIT_CODE