diff --git a/src/planner/rules/partition.rs b/src/planner/rules/partition.rs
index 776b05d1..aea2e622 100644
--- a/src/planner/rules/partition.rs
+++ b/src/planner/rules/partition.rs
@@ -346,7 +346,7 @@ mod tests {
     use super::*;
 
     #[test]
-    fn test_to_parallel() {
+    fn test_hash_join_to_parallel() {
         let input = "
             (hashjoin inner true (list a) (list b)
                 (scan t1 (list a) true)
@@ -355,10 +355,12 @@ mod tests {
         ";
         let distributed = "
             (hashjoin inner true (list a) (list b)
-                (exchange (hash (list a)) 
-                    (scan t1 (list a) true))
-                (exchange (hash (list b)) 
-                    (scan t2 (list b) true))
+                (exchange (hash (list a))
+                    (exchange random
+                        (scan t1 (list a) true)))
+                (exchange (hash (list b))
+                    (exchange random
+                        (scan t2 (list b) true)))
             )
         ";
         let output = to_parallel_plan(input.parse().unwrap());
diff --git a/tests/sql/merge_join.slt b/tests/sql/merge_join.slt
index 4eb543e1..13379858 100644
--- a/tests/sql/merge_join.slt
+++ b/tests/sql/merge_join.slt
@@ -42,7 +42,7 @@ right join (select c, d from t2 order by c) on a = c;
 1    11   1 -11
 NULL NULL 3 -30
 
-query IIII
+query IIII rowsort
 select *
 from (select a, b from t1 order by a) 
 full join (select c, d from t2 order by c) on a = c;