Skip to content

Commit 87d101d

Browse files
committed
Fix isNullAt bug
1 parent abee26d commit 87d101d

File tree

1 file changed

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

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,8 @@ class JoinedRow extends Row {
110110
def apply(i: Int) =
111111
if (i < row1.size) row1(i) else row2(i - row1.size)
112112

113-
def isNullAt(i: Int) = apply(i) == null
113+
def isNullAt(i: Int) =
114+
if (i < row1.size) row1.isNullAt(i) else row2.isNullAt(i - row1.size)
114115

115116
def getInt(i: Int): Int =
116117
if (i < row1.size) row1.getInt(i) else row2.getInt(i - row1.size)

0 commit comments

Comments
 (0)