-
Notifications
You must be signed in to change notification settings - Fork 2k
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
A clear and concise description of what the bug is.
CREATE TEMPORARY TABLE t1 (t1_id INT,t1_name String);
CREATE TEMPORARY TABLE t2 (t2_id INT,t2_name String);
insert into t1 values (11, "a"), (22, "b"), (33, "c"), (44, "d");
insert into t2 values (11, "z"), (22, "y"), (44, "x"), (55, "w");
SELECT t1_id, t1_name, t2_name FROM t1 LEFT JOIN t2 ON (t1_id != t2_id and t2_id >= 100) ORDER BY t1_id;
SparkSQL result:
"+-------+---------+---------+",
"| t1_id | t1_name | t2_name |",
"+-------+---------+---------+",
"| 11 | a | |",
"| 22 | b | |",
"| 33 | c | |",
"| 44 | d | |",
"+-------+---------+---------+",
DataFusion UT
async fn error_cross_join() {
let test_repartition_joins = vec![true, false];
for repartition_joins in test_repartition_joins {
let ctx = create_join_context("t1_id", "t2_id", repartition_joins).unwrap();
let sql = "SELECT t1_id, t1_name, t2_name FROM t1 LEFT JOIN t2 ON (t1_id != t2_id and t2_id >= 100) ORDER BY t1_id";
let actual = execute_to_batches(&ctx, sql).await;
let expected = vec![
"+-------+---------+---------+",
"| t1_id | t1_name | t2_name |",
"+-------+---------+---------+",
"| 11 | a | |",
"| 22 | b | |",
"| 33 | c | |",
"| 44 | d | |",
"+-------+---------+---------+",
];
assert_batches_eq!(expected, &actual);
}
}
actual:
[
"++",
"++",
]
To Reproduce
Steps to reproduce the behavior:
Expected behavior
A clear and concise description of what you expected to happen.
Additional context
Add any other context about the problem here.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working