diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala index 5471134b88467..f84ed41f1d2c3 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoin.scala @@ -365,7 +365,6 @@ case class BroadcastHashJoin( |$numOutput.add(1); |${consume(ctx, input)} """.stripMargin - } else { val matches = ctx.freshName("matches") val bufferType = classOf[CompactBuffer[UnsafeRow]].getName @@ -390,7 +389,6 @@ case class BroadcastHashJoin( |$numOutput.add(1); |${consume(ctx, input)} """.stripMargin - } } }