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(