From c9b707828ef19eb557a214685a6e4995526a1b4f Mon Sep 17 00:00:00 2001 From: yuzelin Date: Fri, 3 Jan 2025 11:45:03 +0800 Subject: [PATCH] [hotfix] Fix flaky test testCleanWithBranch --- .../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 2828101114a1..fcc3f8893f65 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 @@ private FileStoreTable createTableAndWriteData(String tableName) throws Exceptio 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 void testCleanWithBranch(boolean isNamedArgument) throws Exception { // 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(