Skip to content

Commit 777d585

Browse files
committed
Fix
1 parent 7453ab0 commit 777d585

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/ExpressionCodegen.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.sql.catalyst.expressions.codegen
2020
import scala.collection.mutable
2121

2222
import org.apache.spark.sql.catalyst.expressions._
23-
import org.apache.spark.sql.types.DataType
2423

2524
/**
2625
* Defines util methods used in expression code generation.

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastHashJoinExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ case class BroadcastHashJoinExec(
192192
| $value = ${ev.value};
193193
|}
194194
""".stripMargin
195-
ExprCode(code, isNull, value)
195+
ExprCode(code, isNull, value, inputRow = matched)
196196
}
197197
}
198198
}

0 commit comments

Comments
 (0)