This is an automated email from the ASF dual-hosted git repository.
xudong963 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 02cc22eebd Fix ci test (#14625)
02cc22eebd is described below
commit 02cc22eebd7e422cbba6788971f2ffae103180e8
Author: xudong.w <[email protected]>
AuthorDate: Wed Feb 12 19:08:37 2025 +0800
Fix ci test (#14625)
---
datafusion/physical-expr/src/equivalence/class.rs | 3 +--
datafusion/sqllogictest/test_files/join.slt.part | 7 +++----
2 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/datafusion/physical-expr/src/equivalence/class.rs
b/datafusion/physical-expr/src/equivalence/class.rs
index 7ee90bf3fc..187aa8a39e 100644
--- a/datafusion/physical-expr/src/equivalence/class.rs
+++ b/datafusion/physical-expr/src/equivalence/class.rs
@@ -755,12 +755,11 @@ impl Display for EquivalenceGroup {
#[cfg(test)]
mod tests {
-
use super::*;
use crate::equivalence::tests::create_test_params;
use crate::expressions::{binary, col, lit, BinaryExpr, Literal};
+ use arrow::datatypes::{DataType, Field, Schema};
- use arrow_schema::{DataType, Field, Schema};
use datafusion_common::{Result, ScalarValue};
use datafusion_expr::Operator;
diff --git a/datafusion/sqllogictest/test_files/join.slt.part
b/datafusion/sqllogictest/test_files/join.slt.part
index cb90108e76..21126a7479 100644
--- a/datafusion/sqllogictest/test_files/join.slt.part
+++ b/datafusion/sqllogictest/test_files/join.slt.part
@@ -1359,18 +1359,18 @@ physical_plan
06)----------CoalesceBatchesExec: target_batch_size=8192
07)------------RepartitionExec: partitioning=Hash([CAST(f.a AS Int64)@1], 16),
input_partitions=1
08)--------------ProjectionExec: expr=[a@0 as a, CAST(a@0 AS Int64) as
CAST(f.a AS Int64)]
-09)----------------MemoryExec: partitions=1, partition_sizes=[1]
+09)----------------DataSourceExec: partitions=1, partition_sizes=[1]
10)----------CoalesceBatchesExec: target_batch_size=8192
11)------------RepartitionExec: partitioning=Hash([col0@0], 16),
input_partitions=16
12)--------------ProjectionExec: expr=[CAST(x@0 AS Int64) + 1 as col0,
CAST(y@1 AS Int64) + 1 as col1]
13)----------------RepartitionExec: partitioning=RoundRobinBatch(16),
input_partitions=1
14)------------------CoalesceBatchesExec: target_batch_size=8192
15)--------------------FilterExec: y@1 = x@0
-16)----------------------MemoryExec: partitions=1, partition_sizes=[1]
+16)----------------------DataSourceExec: partitions=1, partition_sizes=[1]
17)----CoalesceBatchesExec: target_batch_size=8192
18)------RepartitionExec: partitioning=Hash([CAST(s.b AS Int64)@1], 16),
input_partitions=1
19)--------ProjectionExec: expr=[b@0 as b, CAST(b@0 AS Int64) as CAST(s.b AS
Int64)]
-20)----------MemoryExec: partitions=1, partition_sizes=[1]
+20)----------DataSourceExec: partitions=1, partition_sizes=[1]
statement ok
drop table pairs;
@@ -1387,4 +1387,3 @@ set datafusion.execution.target_partitions = 4;
statement ok
set datafusion.optimizer.repartition_joins = false;
-
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
