Skip to content

Commit

Permalink
chore: safe indexing
Browse files Browse the repository at this point in the history
  • Loading branch information
wiedld committed Oct 4, 2024
1 parent 0a18ba4 commit d1ffc74
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions datafusion/physical-plan/src/union.rs
Original file line number Diff line number Diff line change
Expand Up @@ -475,8 +475,12 @@ fn union_schema(inputs: &[Arc<dyn ExecutionPlan>]) -> SchemaRef {
.filter_map(|input| {
if input.schema().fields().len() > i {
let field = input.schema().field(i).clone();
let right_hand_metdata =
inputs[1].schema().field(i).metadata().clone();
let right_hand_metdata = inputs
.get(1)
.map(|right_input| {
right_input.schema().field(i).metadata().clone()
})
.unwrap_or_default();
let mut metadata = field.metadata().clone();
metadata.extend(right_hand_metdata);
Some(field.with_metadata(metadata))
Expand Down

0 comments on commit d1ffc74

Please sign in to comment.