From b53f589fb35c7723ea0303f611b9623a4c2a960a Mon Sep 17 00:00:00 2001 From: Jingsong Date: Tue, 6 Aug 2024 10:34:08 +0800 Subject: [PATCH] fix --- .../org/apache/paimon/flink/sink/StoreMultiCommitterTest.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/StoreMultiCommitterTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/StoreMultiCommitterTest.java index 832da65f7c13..10e432f3c8c2 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/StoreMultiCommitterTest.java +++ b/paimon-flink/paimon-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(),