From 5607160afaf0f5ecd93fa59b97549bec937991b4 Mon Sep 17 00:00:00 2001 From: Marcelo Vanzin Date: Tue, 10 Oct 2017 10:54:26 -0700 Subject: [PATCH] Small fix. --- .../spark/sql/execution/datasources/AdjustTimestamps.scala | 2 +- 1 file changed, 1 insertion(+), 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 index e6a1680d5db5f..2e57c5ea7dc21 100644 --- 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")