Skip to content

Commit e4f1e9a

Browse files
adriangbCopilot
andcommitted
Update datafusion/datasource-parquet/src/metadata.rs
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
1 parent 403104a commit e4f1e9a

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

datafusion/datasource-parquet/src/metadata.rs

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -634,8 +634,15 @@ pub(crate) fn sort_expr_to_sorting_column(
634634
))
635635
})?;
636636

637+
let column_idx: i32 = column.index().try_into().map_err(|_| {
638+
DataFusionError::Plan(format!(
639+
"Column index {} is too large to be represented as i32",
640+
column.index()
641+
))
642+
})?;
643+
637644
Ok(SortingColumn {
638-
column_idx: column.index() as i32,
645+
column_idx,
639646
descending: sort_expr.options.descending,
640647
nulls_first: sort_expr.options.nulls_first,
641648
})

0 commit comments

Comments
 (0)