disable two flaky flink tests

delta-io · Mar 8, 2024 · 2af89e9 · 2af89e9
1 parent 7b9c4ed
commit 2af89e9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java b/connectors/flink/src/test/java/io/delta/flink/sink/DeltaSinkStreamingExecutionITCase.java
@@ -192,6 +192,9 @@ public void testDeltaSink(boolean isPartitioned, boolean triggerFailover) throws
      *
      * @param exceptionMode whether to throw an exception before or after Delta log commit.
      */
+    @Disabled(
+      "This test is flaky, for some runs it fails with unexpected numbers of files. " +
+      "Investigation of if this is a connector or test issue is ongoing")
     @ResourceLock("StreamingFailoverDeltaGlobalCommitter")
     @ParameterizedTest(name = "isPartitioned = {0}, exceptionMode = {1}")
     @CsvSource({
@@ -335,6 +338,9 @@ public void shouldResumeSink_savepointNoDrainState() throws Exception {
             .hasNoDuplicateAddFiles();
     }
 
+    @Disabled(
+      "This test is flaky, for some runs it fails with 'Seems there was a duplicated AddFile in Delta log'. " +
+      "Investigation of if this is a connector or test issue is ongoing")
     @ParameterizedTest(
         name = "init parallelism level = {0}, parallelism level after resuming job = {1}")
     @CsvSource({"3, 3", "3, 6", "6, 3"})