Skip to content

Commit 8a5d099

Browse files
committed
fix compact_database ut mode value
Signed-off-by: peiyu <125331682@qq.com>
1 parent a1cfc44 commit 8a5d099

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -907,12 +907,15 @@ public void testUnawareBucketStreamingCompact() throws Exception {
907907
if (ThreadLocalRandom.current().nextBoolean()) {
908908
StreamExecutionEnvironment env =
909909
streamExecutionEnvironmentBuilder().streamingMode().build();
910-
createAction(CompactDatabaseAction.class, "compact_database", "--warehouse", warehouse)
910+
createAction(CompactDatabaseAction.class,
911+
"compact_database",
912+
"--warehouse", warehouse,
913+
"--mode", "divided")
911914
.withStreamExecutionEnvironment(env)
912915
.build();
913916
env.executeAsync();
914917
} else {
915-
executeSQL("CALL sys.compact_database()");
918+
executeSQL("CALL sys.compact_database(mode => 'divided')");
916919
}
917920

918921
for (FileStoreTable table : tables) {

0 commit comments

Comments
 (0)