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

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


The following commit(s) were added to refs/heads/release-1.16 by this push:
     new 20eb0168aa6 [FLINK-29419] Disable HybridShuffleITCase.
20eb0168aa6 is described below

commit 20eb0168aa602d1b7a6b8dd116ddd1abeac8dc5e
Author: Weijie Guo <[email protected]>
AuthorDate: Wed Oct 19 11:09:31 2022 +0800

    [FLINK-29419] Disable HybridShuffleITCase.
    
    This test will cause the CI to get stuck. The specific reason needs to be 
further investigated. In order not to block flink code merge pipeline, 
temporarily disable them. We will reactivate these two tests when we find the 
reason.
    
    This closes #21105.
---
 .../test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java
index 898b4de6563..94c40d9cb9c 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java
@@ -27,10 +27,10 @@ import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 /** Tests for hybrid shuffle mode. */
+@Disabled("Enable this test after FLINK-29419 being resolved.")
 class HybridShuffleITCase extends BatchShuffleITCaseBase {
 
     @Test
-    @Disabled("Enable this test after FLINK-29419 being resolved.")
     void testHybridFullExchanges() throws Exception {
         final int numRecordsToSend = 10000;
         Configuration configuration = getConfiguration();
@@ -52,7 +52,6 @@ class HybridShuffleITCase extends BatchShuffleITCaseBase {
     }
 
     @Test
-    @Disabled("Enable this test after FLINK-29419 being resolved.")
     void testHybridFullExchangesRestart() throws Exception {
         final int numRecordsToSend = 10;
         Configuration configuration = getConfiguration();

Reply via email to