This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 69f6af5a70 [python] Fix the row filter on PyArrow 6 (#10557)
69f6af5a70 is described below
commit 69f6af5a709d0bbf9f69e29414858e2d916b23ec
Author: Dapeng Sun(孙大鹏) <[email protected]>
AuthorDate: Thu Oct 15 10:16:49 2026 +0800
[python] Fix the row filter on PyArrow 6 (#10557)
---
paimon-python/pypaimon/read/reader/filter_record_batch_reader.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 e2630f72f4..381536e7c0 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 @@ class FilterRecordBatchReader(RecordBatchReader):
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,
