Fix condition

revolut-engineering · Feb 8, 2024 · b9ee418 · b9ee418
1 parent 46de11c
commit b9ee418
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...k/v3.3/spark/src/main/java/org/apache/iceberg/spark/actions/BaseCopyTableSparkAction.java b/...k/v3.3/spark/src/main/java/org/apache/iceberg/spark/actions/BaseCopyTableSparkAction.java
@@ -693,7 +693,8 @@ record = recordIt.next();
           writer.write(newPositionDeleteRecord(record, sourcePrefix, targetPrefix));
         }
 
-        for (; recordIt.hasNext(); record = recordIt.next()) {
+        while (recordIt.hasNext()) {
+          record = recordIt.next();
           writer.write(newPositionDeleteRecord(record, sourcePrefix, targetPrefix));
         }
       } finally {