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..9e81060712e5 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 @@ -420,7 +420,7 @@ public void testOlderThanTimestamp() throws InterruptedException { long timestamp = System.currentTimeMillis(); - waitUntilAfter(System.currentTimeMillis()); + waitUntilAfter(System.currentTimeMillis() + 1000L); df.write().mode("append").parquet(tableLocation + "/data/c2_trunc=AA/c3=AAAA");