Skip to content

Commit 595ea83

Browse files
chore: add debug logging and skip error on physical schema check
1 parent 34cc054 commit 595ea83

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

722727
let groups = self.create_grouping_physical_expr(

0 commit comments

Comments
 (0)