Make CI green

xudong963 · xudong963 · commit 375d2e676074 · 2025-11-14T15:11:28.000+08:00
diff --git a/datafusion-testing b/datafusion-testing
@@ -1 +1 @@
-Subproject commit f72ac4075ada5ea9810551bc0c3e3161c61204a2
+Subproject commit e9f9e22ccf09145a7368f80fd6a871f11e2b4481
diff --git a/datafusion/common/src/scalar/mod.rs b/datafusion/common/src/scalar/mod.rs
@@ -2387,7 +2387,7 @@ impl ScalarValue {
                 Arc::new(array)
             }
             // explicitly enumerate unsupported types so newly added
-            // types must be aknowledged, Time32 and Time64 types are
+            // types must be acknowledged, Time32 and Time64 types are
             // not supported if the TimeUnit is not valid (Time32 can
             // only be used with Second and Millisecond, Time64 only
             // with Microsecond and Nanosecond)
diff --git a/datafusion/core/src/datasource/listing/table.rs b/datafusion/core/src/datasource/listing/table.rs
@@ -1131,7 +1131,7 @@ impl ListingTable {
     }
 }
 
-// Expressions can be used for parttion pruning if they can be evaluated using
+// Expressions can be used for partition pruning if they can be evaluated using
 // only the partition columns and there are partition columns.
 fn can_be_evaluated_for_partition_pruning(
     partition_column_names: &[&str],
diff --git a/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs b/datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs
@@ -1234,7 +1234,7 @@ async fn test_hashjoin_dynamic_filter_pushdown_partitioned() {
         Arc::new(CoalesceBatchesExec::new(hash_join, 8192)) as Arc<dyn ExecutionPlan>;
     // Top-level CoalescePartitionsExec
     let cp = Arc::new(CoalescePartitionsExec::new(cb)) as Arc<dyn ExecutionPlan>;
-    // Add a sort for determistic output
+    // Add a sort for deterministic output
     let plan = Arc::new(SortExec::new(
         LexOrdering::new(vec![PhysicalSortExpr::new(
             col("a", &probe_side_schema).unwrap(),
diff --git a/datafusion/physical-expr/src/expressions/case.rs b/datafusion/physical-expr/src/expressions/case.rs
@@ -1070,7 +1070,6 @@ mod tests {
         .into_iter()
         .collect();
 
-        //let valid_array = vec![true, false, false, true, false, tru
         let null_buffer = Buffer::from([0b00101001u8]);
         let load4 = load4
             .into_data()
diff --git a/datafusion/sqllogictest/Cargo.toml b/datafusion/sqllogictest/Cargo.toml
@@ -79,7 +79,7 @@ postgres = [
     "tokio-postgres",
 ]
 parquet_encryption = [
-    "datafusion/parquet_encryption"
+    "datafusion/parquet_encryption",
 ]
 
 [dev-dependencies]
diff --git a/datafusion/sqllogictest/test_files/dynamic_filter_pushdown_config.slt b/datafusion/sqllogictest/test_files/dynamic_filter_pushdown_config.slt
@@ -89,7 +89,7 @@ logical_plan
 02)--TableScan: test_parquet projection=[id, value, name]
 physical_plan
 01)SortExec: TopK(fetch=3), expr=[value@1 DESC], preserve_partitioning=[false]
-02)--DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/test_data.parquet]]}, projection=[id, value, name], file_type=parquet, predicate=DynamicFilter [ empty ]
+02)--DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/test_data.parquet]]}, projection=[id, value, name], file_type=parquet, predicate=DynamicFilterPhysicalExpr [ true ]
 
 # Disable TopK dynamic filter pushdown
 statement ok
@@ -127,7 +127,7 @@ physical_plan
 02)--CoalesceBatchesExec: target_batch_size=8192
 03)----HashJoinExec: mode=CollectLeft, join_type=Inner, on=[(id@0, id@0)], projection=[info@1, id@2, data@3]
 04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_right.parquet]]}, projection=[id, info], file_type=parquet
-05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilter [ empty ]
+05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilterPhysicalExpr [ true ]
 
 # Disable Join dynamic filter pushdown
 statement ok
@@ -184,7 +184,7 @@ physical_plan
 02)--CoalesceBatchesExec: target_batch_size=8192
 03)----HashJoinExec: mode=CollectLeft, join_type=Inner, on=[(id@0, id@0)], projection=[info@1, id@2, data@3]
 04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_right.parquet]]}, projection=[id, info], file_type=parquet
-05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilter [ empty ]
+05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilterPhysicalExpr [ true ]
 
 # Enable TopK, disable Join
 statement ok
@@ -306,7 +306,7 @@ physical_plan
 02)--CoalesceBatchesExec: target_batch_size=8192
 03)----HashJoinExec: mode=CollectLeft, join_type=Inner, on=[(id@0, id@0)], projection=[info@1, id@2, data@3]
 04)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_right.parquet]]}, projection=[id, info], file_type=parquet
-05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilter [ empty ]
+05)------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/join_left.parquet]]}, projection=[id, data], file_type=parquet, predicate=DynamicFilterPhysicalExpr [ true ]
 
 # Cleanup
 
diff --git a/docs/source/user-guide/introduction.md b/docs/source/user-guide/introduction.md
@@ -86,7 +86,7 @@ Here are some example systems built using DataFusion:
 By using DataFusion, projects are freed to focus on their specific
 features, and avoid reimplementing general (but still necessary)
 features such as an expression representation, standard optimizations,
-parellelized streaming execution plans, file format support, etc.
+parallelized streaming execution plans, file format support, etc.
 
 ## Known Users
 
diff --git a/typos.toml b/typos.toml
@@ -34,6 +34,9 @@ alph = "alph"
 wih = "wih"
 Ded = "Ded"
 
+# From SLT README
+nteger = "nteger"
+
 [files]
 extend-exclude = [
     "*.slt",
@@ -42,5 +45,6 @@ extend-exclude = [
     "*.sql",
     "dev/changelog/**",
     "benchmarks/**",
-    "*.csv"
+    "*.csv",
+    "docs/source/contributor-guide/governance.md"
 ]

Original file line number	Diff line number	Diff line change
`@@ -2387,7 +2387,7 @@ impl ScalarValue {`
`2387`	`2387`	`Arc::new(array)`
`2388`	`2388`	`}`
`2389`	`2389`	`// explicitly enumerate unsupported types so newly added`
`2390`		`- // types must be aknowledged, Time32 and Time64 types are`
	`2390`	`+ // types must be acknowledged, Time32 and Time64 types are`
`2391`	`2391`	`// not supported if the TimeUnit is not valid (Time32 can`
`2392`	`2392`	`// only be used with Second and Millisecond, Time64 only`
`2393`	`2393`	`// with Microsecond and Nanosecond)`
Original file line number	Diff line number	Diff line change
`@@ -1131,7 +1131,7 @@ impl ListingTable {`
`1131`	`1131`	`}`
`1132`	`1132`	`}`
`1133`	`1133`
`1134`		`-// Expressions can be used for parttion pruning if they can be evaluated using`
	`1134`	`+// Expressions can be used for partition pruning if they can be evaluated using`
`1135`	`1135`	`// only the partition columns and there are partition columns.`
`1136`	`1136`	`fn can_be_evaluated_for_partition_pruning(`
`1137`	`1137`	`partition_column_names: &[&str],`
Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ postgres = [`
`79`	`79`	`"tokio-postgres",`
`80`	`80`	`]`
`81`	`81`	`parquet_encryption = [`
`82`		`- "datafusion/parquet_encryption"`
	`82`	`+ "datafusion/parquet_encryption",`
`83`	`83`	`]`
`84`	`84`
`85`	`85`	`[dev-dependencies]`