(iceberg) branch main updated: Flink: Disabling flaky test TestIcebergSourceFailover.testBoundedWithSavepoint (#10802)

[pvary]

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

pvary pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new 2c42e67375 Flink: Disabling flaky test 
TestIcebergSourceFailover.testBoundedWithSavepoint (#10802)
2c42e67375 is described below

commit 2c42e673757aeeede3a4d537eeb199254496e1c5
Author: pvary <peter.vary.apa...@gmail.com>
AuthorDate: Mon Jul 29 10:06:22 2024 +0200

    Flink: Disabling flaky test 
TestIcebergSourceFailover.testBoundedWithSavepoint (#10802)
---
 .../java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java | 2 ++
 .../java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java | 2 ++
 .../java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java | 2 ++
 3 files changed, 6 insertions(+)

diff --git 
a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
 
b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
index 62558fc9c8..938ae4d9bb 100644
--- 
a/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
+++ 
b/flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
@@ -63,6 +63,7 @@ import org.apache.iceberg.flink.sink.FlinkSink;
 import org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory;
 import org.apache.iceberg.relocated.com.google.common.collect.Lists;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -137,6 +138,7 @@ public class TestIcebergSourceFailover {
     SimpleDataUtil.assertTableRecords(table, expectedRecords, timeout);
   }
 
+  @Disabled("Disabled for now as it is flaky on CI")
   @Test
   public void testBoundedWithSavepoint(@InjectClusterClient ClusterClient<?> 
clusterClient)
       throws Exception {
diff --git 
a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
 
b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
index 62558fc9c8..938ae4d9bb 100644
--- 
a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
+++ 
b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
@@ -63,6 +63,7 @@ import org.apache.iceberg.flink.sink.FlinkSink;
 import org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory;
 import org.apache.iceberg.relocated.com.google.common.collect.Lists;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -137,6 +138,7 @@ public class TestIcebergSourceFailover {
     SimpleDataUtil.assertTableRecords(table, expectedRecords, timeout);
   }
 
+  @Disabled("Disabled for now as it is flaky on CI")
   @Test
   public void testBoundedWithSavepoint(@InjectClusterClient ClusterClient<?> 
clusterClient)
       throws Exception {
diff --git 
a/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
 
b/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
index 62558fc9c8..938ae4d9bb 100644
--- 
a/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
+++ 
b/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java
@@ -63,6 +63,7 @@ import org.apache.iceberg.flink.sink.FlinkSink;
 import org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory;
 import org.apache.iceberg.relocated.com.google.common.collect.Lists;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -137,6 +138,7 @@ public class TestIcebergSourceFailover {
     SimpleDataUtil.assertTableRecords(table, expectedRecords, timeout);
   }
 
+  @Disabled("Disabled for now as it is flaky on CI")
   @Test
   public void testBoundedWithSavepoint(@InjectClusterClient ClusterClient<?> 
clusterClient)
       throws Exception {