You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2025/04/23 12:26:04 UTC
(paimon) branch master updated: [test] Fix unstable CompactDatabaseActionITCase#testCombinedModeWithDynamicOptions (#5520)
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 <li...@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(