diff --git a/spark/v3.2/spark/src/test/java/org/apache/iceberg/spark/actions/TestRemoveOrphanFilesAction.java b/spark/v3.2/spark/src/test/java/org/apache/iceberg/spark/actions/TestRemoveOrphanFilesAction.java index bcabe38e79f1..c1b0ddae8efb 100644 --- a/spark/v3.2/spark/src/test/java/org/apache/iceberg/spark/actions/TestRemoveOrphanFilesAction.java +++ b/spark/v3.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);