diff --git a/datafusion/core/src/datasource/memory.rs b/datafusion/core/src/datasource/memory.rs index 58fa145d7b742..7c61cc5368608 100644 --- a/datafusion/core/src/datasource/memory.rs +++ b/datafusion/core/src/datasource/memory.rs @@ -65,10 +65,6 @@ impl MemTable { pub fn try_new(schema: SchemaRef, partitions: Vec>) -> Result { for batches in partitions.iter().flatten() { let batches_schema = batches.schema(); - println!( - "the new schema is {:?}, schema set is {:?}", - batches_schema, schema - ); if !schema.contains(&batches_schema) { debug!( "mem table schema does not contain batches schema. \ diff --git a/datafusion/expr/src/logical_plan/builder.rs b/datafusion/expr/src/logical_plan/builder.rs index 2efe45471ca91..7c85842cd9d92 100644 --- a/datafusion/expr/src/logical_plan/builder.rs +++ b/datafusion/expr/src/logical_plan/builder.rs @@ -1204,7 +1204,6 @@ pub fn build_join_schema( right_fields.clone() } }; - //println!("total fields is {:?}", fields); let func_dependencies = left.functional_dependencies().join( right.functional_dependencies(), join_type, @@ -1212,7 +1211,6 @@ pub fn build_join_schema( ); let mut metadata = left.metadata().clone(); metadata.extend(right.metadata().clone()); - // let schema = DFSchema::new_with_metadata(change_redundant_column(fields), metadata)?; let schema = DFSchema::new_with_metadata(fields, metadata)?; schema.with_functional_dependencies(func_dependencies) } @@ -1268,7 +1266,6 @@ pub(crate) fn validate_unique_names<'a>( Ok(()) }, Some((existing_position, existing_expr)) => { - //println!("node_name is {}, existing expr is {:?}", node_name, existing_expr); plan_err!("{node_name} require unique expression names \ but the expression \"{existing_expr}\" at position {existing_position} and \"{expr}\" \ at position {position} have the same name. Consider aliasing (\"AS\") one of them."