[flink] branch release-1.16 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 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 5d03327d016 [FLINK-29419] Disable testHybridFullExchanges and 
testHybridFullExchangesRestart in HybridShuffleITCase temporarily.
5d03327d016 is described below

commit 5d03327d016c6e3250a82566ff5530c65cf5d344
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();