(arrow-datafusion) branch main updated: Update checking columns in schema merge (#8765)

[alamb]

This is an automated email from the ASF dual-hosted git repository.

alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


The following commit(s) were added to refs/heads/main by this push:
     new 6e7529734c Update checking columns in schema merge (#8765)
6e7529734c is described below

commit 6e7529734ccb7ddc86129b8c6b490d51ec7054d9
Author: Matthew Turner <matthew.m.tur...@outlook.com>
AuthorDate: Fri Jan 5 15:36:41 2024 -0500

    Update checking columns in schema merge (#8765)
---
 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 d6e4490cec..8772c4c3e1 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());