Spark: Fix flaky time dependent test for remove orphan files (apache#…

…4859)
yabola · May 27, 2022 · 35aa9fe · 35aa9fe
1 parent fc66a94
commit 35aa9fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...3.2/spark/src/test/java/org/apache/iceberg/spark/actions/TestRemoveOrphanFilesAction.java b/...3.2/spark/src/test/java/org/apache/iceberg/spark/actions/TestRemoveOrphanFilesAction.java
@@ -303,7 +303,7 @@ public void orphanedFileRemovedWithParallelTasks() throws InterruptedException,
 
     DeleteOrphanFiles.Result result = SparkActions.get().deleteOrphanFiles(table)
             .executeDeleteWith(executorService)
-            .olderThan(System.currentTimeMillis())
+            .olderThan(System.currentTimeMillis() + 5000)  // Ensure all orphan files are selected
             .deleteWith(file -> {
               deleteThreads.add(Thread.currentThread().getName());
               deletedFiles.add(file);