fix tests

pyiceberg/expressions/__init__.py

@@ -351,7 +351,6 @@ def __eq__(self, other: Any) -> bool:
     @abstractmethod
     def as_unbound(self) -> Type[UnboundPredicate[Any]]: ...
 
-
     def __hash__(self) -> int:
         """Return hash value of the BoundPredicate class."""
         return hash(str(self))
@@ -393,8 +392,6 @@ def __repr__(self) -> str:
     def as_bound(self) -> Type[BoundUnaryPredicate[Any]]: ...
 
 
-
-
 class BoundUnaryPredicate(BoundPredicate[L], ABC):
     def __repr__(self) -> str:
         """Return the string representation of the BoundUnaryPredicate class."""
@@ -751,7 +748,6 @@ def as_unbound(self) -> Type[EqualTo[L]]:
         return EqualTo
 
 
-
 class BoundNotEqualTo(BoundLiteralPredicate[L]):
     def __invert__(self) -> BoundEqualTo[L]:
         """Transform the Expression into its negated version."""

pyiceberg/io/pyarrow.py

@@ -1776,7 +1776,6 @@ def write_parquet(task: WriteTask) -> DataFile:
         fo = io.new_output(file_path)
         with fo.create(overwrite=True) as fos:
             with pq.ParquetWriter(fos, schema=arrow_file_schema, **parquet_writer_kwargs) as writer:
-                writer.write(pa.Table.from_batches(task.record_batches), row_group_size=row_group_size)
                 arrow_table = pa.Table.from_batches(task.record_batches)
                 # align the columns accordingly in case input arrow table has columns in order different from iceberg table
                 df_to_write = arrow_table.select(arrow_file_schema.names)

tests/table/test_init.py

@@ -18,7 +18,7 @@
 import re
 import uuid
 from copy import copy
-from typing import Any, Dict, Set, Union, List
+from typing import Any, Dict, List, Union
 
 import pyarrow as pa
 import pytest