Skip to content

Commit 4e7ad0d

Browse files
chore: re-enable physical schema check and log a warning instead of error
1 parent 7de4de5 commit 4e7ad0d

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

datafusion/core/src/physical_planner.rs

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -712,10 +712,15 @@ impl DefaultPhysicalPlanner {
712712
differences.push(format!("field nullability at index {} [{}]: (physical) {} vs (logical) {}", i, physical_field.name(), physical_field.is_nullable(), logical_field.is_nullable()));
713713
}
714714
}
715-
return internal_err!("Physical input schema should be the same as the one converted from logical input schema. Differences: {}", differences
716-
.iter()
717-
.map(|s| format!("\n\t- {s}"))
718-
.join(""));
715+
716+
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());
717+
718+
//influx: temporarily remove error and only log so that we can find a
719+
//reproducer in production
720+
// return internal_err!("Physical input schema should be the same as the one converted from logical input schema. Differences: {}", differences
721+
// .iter()
722+
// .map(|s| format!("\n\t- {s}"))
723+
// .join(""));
719724
}
720725

721726
let groups = self.create_grouping_physical_expr(

0 commit comments

Comments
 (0)