[flink] branch master updated: [FLINK-29419] Disable testHybridFullExchanges and testHybridFullExchangesRestart in HybridShuffleITCase temporarily.

[hxb]

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

hxb 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 fca71d237b2 [FLINK-29419] Disable testHybridFullExchanges and 
testHybridFullExchangesRestart in HybridShuffleITCase temporarily.
fca71d237b2 is described below

commit fca71d237b2440c0129ef7e6f8266f4091df4884
Author: Weijie Guo <res...@163.com>
AuthorDate: Mon Oct 17 13:36:10 2022 +0800

    [FLINK-29419] Disable testHybridFullExchanges and 
testHybridFullExchangesRestart in HybridShuffleITCase temporarily.
    
    These two tests 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 #21081.
---
 .../test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java   | 3 +++
 1 file changed, 3 insertions(+)

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 2df7fd93fa2..898b4de6563 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
@@ -23,12 +23,14 @@ import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.ExecutionOptions;
 import org.apache.flink.runtime.jobgraph.JobGraph;
 
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 /** Tests for hybrid shuffle mode. */
 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();
@@ -50,6 +52,7 @@ 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();