diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py
index 2fdee17441..cde6d94709 100644
--- a/pyiceberg/io/pyarrow.py
+++ b/pyiceberg/io/pyarrow.py
@@ -1492,7 +1492,7 @@ def _task_to_record_batches(
 
                 current_batch = table.combine_chunks().to_batches()[0]
 
-            result_batch = _to_requested_schema(
+            yield _to_requested_schema(
                 projected_schema,
                 file_project_schema,
                 current_batch,
@@ -1500,8 +1500,6 @@ def _task_to_record_batches(
                 projected_missing_fields=projected_missing_fields,
             )
 
-            yield result_batch
-
 
 def _read_all_delete_files(io: FileIO, tasks: Iterable[FileScanTask]) -> Dict[str, List[ChunkedArray]]:
     deletes_per_file: Dict[str, List[ChunkedArray]] = {}