This is an automated email from the ASF dual-hosted git repository.
JingsongLi 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 e3a9a4a2fd [test] Fix test error in CompactActionITCase
e3a9a4a2fd is described below
commit e3a9a4a2fd4fc8a2de943bc40974623d296ff939
Author: JingsongLi <[email protected]>
AuthorDate: Sun May 24 20:23:41 2026 +0800
[test] Fix test error in CompactActionITCase
---
.../java/org/apache/paimon/flink/action/CompactActionITCase.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java
index cb7cf87f60..646a20ac70 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java
@@ -429,8 +429,12 @@ public class CompactActionITCase extends
CompactActionITCaseBase {
rowData(1, 101, 15, BinaryString.fromString("20221208"), 1),
rowData(1, 101, 16, BinaryString.fromString("20221208"), 1),
rowData(2, 101, 15, BinaryString.fromString("20221209"), 2));
- checkLatestSnapshot(table, 4, Snapshot.CommitKind.COMPACT, 60_000);
+ // The old streaming compact job will fail because it detects files
with a newer schema.
+ // Run a new compact action to compact with the new schema.
+ runAction(false);
+
+ table = getFileStoreTable(tableName);
List<String> res =
getResult(
table.newRead(),
