diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala index a099fadcec365..06ca139870804 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala @@ -294,7 +294,7 @@ case class AttributeReference( } override lazy val preCanonicalized: Expression = { - AttributeReference("none", dataType.asNullable)(exprId) + AttributeReference("none", dataType)(exprId) } override def newInstance(): AttributeReference =