Skip to content

Commit 8c7f749

Browse files
committed
Fix the problematic case.
1 parent 6368702 commit 8c7f749

File tree

1 file changed

+2
-2
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions

1 file changed

+2
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,9 +126,9 @@ abstract class Expression extends TreeNode[Expression] {
126126
eval.inputRow = ctx.INPUT_ROW
127127
}
128128
if (ctx.currentVars != null) {
129-
val boundRefs = children.flatMap(_.collect {
129+
val boundRefs = this.collect {
130130
case b @ BoundReference(ordinal, _, _) if ctx.currentVars(ordinal) != null => (ordinal, b)
131-
}).toMap
131+
}.toMap
132132

133133
ctx.currentVars.zipWithIndex.filter(_._1 != null).foreach { case (currentVar, idx) =>
134134
if (boundRefs.contains(idx)) {

0 commit comments

Comments
 (0)