Small fix.

apache · Oct 10, 2017 · 5607160 · 5607160
1 parent 5c03e07
commit 5607160
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/AdjustTimestamps.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/AdjustTimestamps.scala
@@ -86,7 +86,7 @@ case class AdjustTimestamps(conf: SQLConf) extends Rule[LogicalPlan] {
           Alias(adjustment, e.name)()
 
         case other: NamedExpression =>
-          other
+          other.toAttribute
 
         case unnamed =>
           throw new AnalysisException(s"Unexpected expr: $unnamed")