diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py index 3e49885e58..e93a514db6 100644 --- a/pyiceberg/io/pyarrow.py +++ b/pyiceberg/io/pyarrow.py @@ -2404,9 +2404,12 @@ def data_file_statistics_from_parquet_metadata( continue if field_id not in col_aggs: - col_aggs[field_id] = StatsAggregator( - stats_col.iceberg_type, statistics.physical_type, stats_col.mode.length - ) + try: + col_aggs[field_id] = StatsAggregator( + stats_col.iceberg_type, statistics.physical_type, stats_col.mode.length + ) + except ValueError as e: + raise ValueError(f"{e} for column '{stats_col.column_name}'") from e if isinstance(stats_col.iceberg_type, DecimalType) and statistics.physical_type != "FIXED_LEN_BYTE_ARRAY": scale = stats_col.iceberg_type.scale