Revert optimization for BroadcastNestedLoopJoin (this fixes tests).

apache · Jul 29, 2014 · 43d38a6 · 43d38a6
1 parent 0ef9e5b
commit 43d38a6
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala
@@ -152,11 +152,8 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
   object BroadcastNestedLoopJoin extends Strategy {
     def apply(plan: LogicalPlan): Seq[SparkPlan] = plan match {
       case logical.Join(left, right, joinType, condition) =>
-        val (streamed, broadcast) =
-          if (right.statistics.sizeInBytes <= left.statistics.sizeInBytes) (left, right)
-          else (right, left)
         execution.BroadcastNestedLoopJoin(
-          planLater(streamed), planLater(broadcast), joinType, condition)(sqlContext) :: Nil
+          planLater(left), planLater(right), joinType, condition)(sqlContext) :: Nil
       case _ => Nil
     }
   }