Merge pull request #25 from Ackuq/fix/distribution

Fix partitioning distribution of data when no equiality join
Ackuq · May 5, 2022 · b34ab6d · b34ab6d
2 parents a4efcc1 + 29b5b09
commit b34ab6d
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