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 00cf16efe1 [hotfix] Fix flaky test testCleanWithBranch (#4826)
00cf16efe1 is described below
commit 00cf16efe1c77d9f9943b4f4bd29bcbdab91e390
Author: yuzelin <[email protected]>
AuthorDate: Fri Jan 3 13:08:02 2025 +0800
[hotfix] Fix flaky test testCleanWithBranch (#4826)
---
.../apache/paimon/flink/action/RemoveOrphanFilesActionITCaseBase.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionITCaseBase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionITCaseBase.java
index 2828101114..fcc3f8893f 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionITCaseBase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/RemoveOrphanFilesActionITCaseBase.java
@@ -87,8 +87,8 @@ public abstract class RemoveOrphanFilesActionITCaseBase
extends ActionITCaseBase
FileIO fileIO = table.fileIO();
fileIO.writeFile(orphanFile1, "a", true);
- Thread.sleep(2000);
fileIO.writeFile(orphanFile2, "b", true);
+ Thread.sleep(2000);
return table;
}
@@ -263,6 +263,7 @@ public abstract class RemoveOrphanFilesActionITCaseBase
extends ActionITCaseBase
// create orphan file in snapshot directory of second branch
Path orphanFile4 = new Path(table.location(),
"branch/branch-br2/snapshot/orphan_file4");
branchTable.fileIO().writeFile(orphanFile4, "y", true);
+ Thread.sleep(2000);
if (ThreadLocalRandom.current().nextBoolean()) {
executeSQL(
