Skip to content

Commit 658c5e3

Browse files
committed
Fix nullability of map values of ExternalMapToCatalyst.
1 parent 0fc36a8 commit 658c5e3

File tree

1 file changed

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

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -601,7 +601,8 @@ case class ExternalMapToCatalyst private(
601601

602602
override def foldable: Boolean = false
603603

604-
override def dataType: MapType = MapType(keyConverter.dataType, valueConverter.dataType)
604+
override def dataType: MapType = MapType(
605+
keyConverter.dataType, valueConverter.dataType, valueContainsNull = valueConverter.nullable)
605606

606607
override def eval(input: InternalRow): Any =
607608
throw new UnsupportedOperationException("Only code-generated evaluation is supported")

0 commit comments

Comments
 (0)