From c2bf94f66ee57806ae7cc3562cb8832901d9e4b4 Mon Sep 17 00:00:00 2001 From: Matthew Turner Date: Fri, 5 Jan 2024 11:25:55 -0500 Subject: [PATCH] Update checking columns in schema merge --- datafusion/common/src/dfschema.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datafusion/common/src/dfschema.rs b/datafusion/common/src/dfschema.rs index d6e4490cec4c1..8772c4c3e1ff5 100644 --- a/datafusion/common/src/dfschema.rs +++ b/datafusion/common/src/dfschema.rs @@ -230,9 +230,9 @@ impl DFSchema { for field in other_schema.fields() { // skip duplicate columns let duplicated_field = match field.qualifier() { - Some(q) => self.field_with_name(Some(q), field.name()).is_ok(), + Some(q) => self.has_column_with_qualified_name(q, field.name()), // for unqualified columns, check as unqualified name - None => self.field_with_unqualified_name(field.name()).is_ok(), + None => self.has_column_with_unqualified_name(field.name()), }; if !duplicated_field { self.fields.push(field.clone());