diff --git a/paimon-python/pypaimon/read/reader/filter_record_batch_reader.py b/paimon-python/pypaimon/read/reader/filter_record_batch_reader.py index e2630f72f44d..381536e7c0da 100644 --- a/paimon-python/pypaimon/read/reader/filter_record_batch_reader.py +++ b/paimon-python/pypaimon/read/reader/filter_record_batch_reader.py @@ -97,8 +97,8 @@ def _filter_batch_by_row(self, batch: pa.RecordBatch) -> Optional[pa.RecordBatch columns = ([field.name for field in self.schema_fields] if self.schema_fields is not None else [name for name in batch.schema.names if name != "_row_kind"]) - logical_batch = batch.select(columns) - df = polars.from_arrow(pa.Table.from_batches([logical_batch])) + # PyArrow 6 has Table.select but not RecordBatch.select. + df = polars.from_arrow(pa.Table.from_batches([batch]).select(columns)) iterator = InternalRowWrapperIterator( self._iter_df_rows(df), df.width,