Skip to content

Commit df1ae53

Browse files
committed
Modify nullabilize to leave attribute if not resolved.
1 parent 799ce56 commit df1ae53

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ case class Generate(
5252
.getOrElse(generator.output)
5353
if (join && outer) {
5454
output.map {
55+
case attr if !attr.resolved => attr
5556
case attr if !attr.nullable =>
5657
AttributeReference(
5758
attr.name, attr.dataType, nullable = true)(attr.exprId, attr.qualifiers)
@@ -95,6 +96,7 @@ case class Join(
9596
override def output = {
9697
def nullabilize(output: Seq[Attribute]) = {
9798
output.map {
99+
case attr if !attr.resolved => attr
98100
case attr if !attr.nullable =>
99101
AttributeReference(
100102
attr.name, attr.dataType, nullable = true)(attr.exprId, attr.qualifiers)

0 commit comments

Comments
 (0)