Fix partitioning distribution of data when no equiality join

Ackuq · May 5, 2022 · 29b5b09 · 29b5b09
1 parent a4efcc1
commit 29b5b09
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/scala/src/main/scala/execution/PITJoinExec.scala b/scala/src/main/scala/execution/PITJoinExec.scala
@@ -72,7 +72,8 @@ protected[pit] case class PITJoinExec(
 
   override def requiredChildDistribution: Seq[Distribution] = {
     if (leftEquiKeys.isEmpty || rightEquiKeys.isEmpty) {
-      UnspecifiedDistribution :: UnspecifiedDistribution :: Nil
+      // TODO: This should be improved, but for now just keep everything in one partition
+      AllTuples :: AllTuples :: Nil
     } else {
       HashClusteredDistribution(leftEquiKeys) :: HashClusteredDistribution(
         rightEquiKeys