Skip to content

Commit 3943c98

Browse files
committed
fix unit test
Signed-off-by: Runji Wang <[email protected]>
1 parent 321e330 commit 3943c98

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

src/planner/rules/partition.rs

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,7 @@ mod tests {
346346
use super::*;
347347

348348
#[test]
349-
fn test_to_parallel() {
349+
fn test_hash_join_to_parallel() {
350350
let input = "
351351
(hashjoin inner true (list a) (list b)
352352
(scan t1 (list a) true)
@@ -355,10 +355,12 @@ mod tests {
355355
";
356356
let distributed = "
357357
(hashjoin inner true (list a) (list b)
358-
(exchange (hash (list a))
359-
(scan t1 (list a) true))
360-
(exchange (hash (list b))
361-
(scan t2 (list b) true))
358+
(exchange (hash (list a))
359+
(exchange random
360+
(scan t1 (list a) true)))
361+
(exchange (hash (list b))
362+
(exchange random
363+
(scan t2 (list b) true)))
362364
)
363365
";
364366
let output = to_parallel_plan(input.parse().unwrap());

tests/sql/merge_join.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ right join (select c, d from t2 order by c) on a = c;
4242
1 11 1 -11
4343
NULL NULL 3 -30
4444

45-
query IIII
45+
query IIII rowsort
4646
select *
4747
from (select a, b from t1 order by a)
4848
full join (select c, d from t2 order by c) on a = c;

0 commit comments

Comments
 (0)