fix: Fixed bug in left outer join

All the records from the end of a DataFrame would go missing from a left outer join due to typo in code.
audienceproject · Dec 12, 2022 · 0504310 · 0504310
1 parent 1679bc3
commit 0504310
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/audienceproject/crossbow/algorithms/SortMergeJoin.scala b/src/main/scala/com/audienceproject/crossbow/algorithms/SortMergeJoin.scala
@@ -61,7 +61,7 @@ private[crossbow] object SortMergeJoin {
       }
     }
 
-    if (leftSet.nonEmpty && isLeftJoin) addCartesianProduct(leftSet.head until leftSet.size, Seq(-1))
+    if (leftSet.nonEmpty && isLeftJoin) addCartesianProduct(leftSet.head until leftKey.size, Seq(-1))
     if (rightSet.nonEmpty && isRightJoin) addCartesianProduct(Seq(-1), rightSet.head until rightKey.size)
 
     val leftFinal = left.slice(leftResult.toIndexedSeq)