fix

apache · Aug 6, 2024 · b53f589 · b53f589
1 parent 698927d
commit b53f589
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...imon-flink-common/src/test/java/org/apache/paimon/flink/sink/StoreMultiCommitterTest.java b/...imon-flink-common/src/test/java/org/apache/paimon/flink/sink/StoreMultiCommitterTest.java
@@ -70,6 +70,7 @@
 import java.util.Objects;
 import java.util.UUID;
 
+import static org.apache.paimon.CoreOptions.COMPACTION_MAX_FILE_NUM;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.fail;
 
@@ -131,6 +132,7 @@ public void beforeEach() throws Exception {
         Options secondOptions = new Options();
         secondOptions.setString("bucket", "1");
         secondOptions.setString("bucket-key", "a");
+        secondOptions.set(COMPACTION_MAX_FILE_NUM, 50);
         Schema secondTableSchema =
                 new Schema(
                         rowType2.getFields(),