Flink: Increase the number of checkpoints from 4 to 6 to fix flakines…

…s. (#11121) 6 checkpoionts cycles seem to be more stable based on the existing TestFlinkIcebergSinkDistributionMode test.
apache · Sep 16, 2024 · 5ce7c30 · 5ce7c30
1 parent 2e4d5b5
commit 5ce7c30
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...st/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java b/...st/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java
@@ -98,7 +98,7 @@ public class TestFlinkIcebergSinkRangeDistributionBucketing {
       new HadoopCatalogExtension(TestFixtures.DATABASE, TestFixtures.TABLE);
 
   private static final int NUM_BUCKETS = 4;
-  private static final int NUM_OF_CHECKPOINTS = 4;
+  private static final int NUM_OF_CHECKPOINTS = 6;
   private static final int ROW_COUNT_PER_CHECKPOINT = 200;
   private static final Schema SCHEMA =
       new Schema(

diff --git a/...st/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java b/...st/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkRangeDistributionBucketing.java
@@ -98,7 +98,7 @@ public class TestFlinkIcebergSinkRangeDistributionBucketing {
       new HadoopCatalogExtension(TestFixtures.DATABASE, TestFixtures.TABLE);
 
   private static final int NUM_BUCKETS = 4;
-  private static final int NUM_OF_CHECKPOINTS = 4;
+  private static final int NUM_OF_CHECKPOINTS = 6;
   private static final int ROW_COUNT_PER_CHECKPOINT = 200;
   private static final Schema SCHEMA =
       new Schema(