From 4c484a6ae8d04fae9feccb05225595e72fc0ca00 Mon Sep 17 00:00:00 2001 From: wiedld Date: Tue, 15 Oct 2024 12:51:48 -0700 Subject: [PATCH] chore: temp patch to convert errors to logged warnings, for schema mismatch in aggregates --- datafusion/core/src/physical_planner.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/core/src/physical_planner.rs b/datafusion/core/src/physical_planner.rs index cf2a157b04b6..49a9da02ea7b 100644 --- a/datafusion/core/src/physical_planner.rs +++ b/datafusion/core/src/physical_planner.rs @@ -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(