diff --git a/chdb/dataframe/query.py b/chdb/dataframe/query.py index 64d43fa6f65..6c83e8d57a0 100644 --- a/chdb/dataframe/query.py +++ b/chdb/dataframe/query.py @@ -186,10 +186,7 @@ def _run_on_temp(self, fd: int, temp_path: str = None, sql: str = None, fmt: str def pandas_read_parquet(path) -> pd.DataFrame: - if pd.__version__[0] >= '1': - return pd.read_parquet(path, engine='pyarrow', dtype_backend='pyarrow') - else: - return pd.read_parquet(path) + return pd.read_parquet(path) def memfd_create(name: str = None) -> int: