(paimon) branch master updated: [test] Fix unstable CompactDatabaseActionITCase#testCombinedModeWithDynamicOptions (#5520)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 10ce5aa73e [test] Fix unstable 
CompactDatabaseActionITCase#testCombinedModeWithDynamicOptions (#5520)
10ce5aa73e is described below

commit 10ce5aa73ebe2ac71d2e5387c37920e4e06ee33b
Author: Yubin Li <lixin58...@163.com>
AuthorDate: Wed Apr 23 20:25:59 2025 +0800

    [test] Fix unstable 
CompactDatabaseActionITCase#testCombinedModeWithDynamicOptions (#5520)
---
 .../org/apache/paimon/flink/action/CompactDatabaseActionITCase.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java
index dd5b4c03ea..acb0267440 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java
@@ -1045,8 +1045,7 @@ public class CompactDatabaseActionITCase extends 
CompactActionITCaseBase {
                         "--table_conf",
                         CoreOptions.SNAPSHOT_NUM_RETAINED_MAX.key() + "=3");
 
-        StreamExecutionEnvironment env =
-                streamExecutionEnvironmentBuilder().streamingMode().build();
+        StreamExecutionEnvironment env = 
streamExecutionEnvironmentBuilder().batchMode().build();
         action.withStreamExecutionEnvironment(env).build();
         JobClient jobClient = env.executeAsync();
 
@@ -1054,7 +1053,6 @@ public class CompactDatabaseActionITCase extends 
CompactActionITCaseBase {
                 () -> snapshotManager.latestSnapshotId() == 11L,
                 Duration.ofSeconds(240),
                 Duration.ofMillis(500));
-        jobClient.cancel();
 
         assertThat(snapshotManager.latestSnapshot().commitKind())
                 .isEqualTo(Snapshot.CommitKind.COMPACT);
@@ -1072,6 +1070,7 @@ public class CompactDatabaseActionITCase extends 
CompactActionITCaseBase {
                 splits.get(0).dataFiles().stream()
                         .anyMatch(file -> 
file.fileFormat().equalsIgnoreCase("avro"));
         assertThat(hasAvroFile).isTrue();
+        jobClient.cancel();
     }
 
     private void writeData(