Skip to content

Commit

Permalink
chore: temp patch to convert errors to logged warnings, for schema mi…
Browse files Browse the repository at this point in the history
…smatch in aggregates
  • Loading branch information
wiedld authored and alamb committed Dec 6, 2024
1 parent 7bc1969 commit c898129
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion datafusion/core/src/physical_planner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -658,7 +658,7 @@ impl DefaultPhysicalPlanner {
logical_input_schema.as_ref().clone().into();

if physical_input_schema != physical_input_schema_from_logical {
return internal_err!("Physical input schema should be the same as the one converted from logical input schema.");
log::warn!("Physical input schema should be the same as the one converted from logical input schema, but did not match for logical plan:\n{}", input.display_indent());
}

let groups = self.create_grouping_physical_expr(
Expand Down

0 comments on commit c898129

Please sign in to comment.