Skip to content

Commit ce74530

Browse files
chore: re-enable physical schema check
1 parent 200feea commit ce74530

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
@@ -710,10 +710,15 @@ impl DefaultPhysicalPlanner {
710710
differences.push(format!("field nullability at index {} [{}]: (physical) {} vs (logical) {}", i, physical_field.name(), physical_field.is_nullable(), logical_field.is_nullable()));
711711
}
712712
}
713-
return internal_err!("Physical input schema should be the same as the one converted from logical input schema. Differences: {}", differences
714-
.iter()
715-
.map(|s| format!("\n\t- {s}"))
716-
.join(""));
713+
714+
//influx: temporarily remove error and logging so that we can find a
715+
//reproducer in production. Once resolved, we can uncomment the error and
716+
//delete the logging.
717+
// 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());
718+
// return internal_err!("Physical input schema should be the same as the one converted from logical input schema. Differences: {}", differences
719+
// .iter()
720+
// .map(|s| format!("\n\t- {s}"))
721+
// .join(""));
717722
}
718723

719724
let groups = self.create_grouping_physical_expr(

0 commit comments

Comments
 (0)