From 12a239eab0067870e98b1ede4a2e30023248b556 Mon Sep 17 00:00:00 2001 From: wangfei Date: Mon, 26 Jan 2015 13:30:10 +0800 Subject: [PATCH] fix test case --- .../scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala index e0a49d715c3a0..5b3fae8ff0d07 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala @@ -419,6 +419,8 @@ class Analyzer(catalog: Catalog, def apply(plan: LogicalPlan): LogicalPlan = plan transform { case Project(Seq(Alias(g: Generator, _)), child) => Generate(g, join = false, outer = false, None, child) + case Project(Seq(MultiAlias(g: Generator, _)), child) => + Generate(g, join = false, outer = false, None, child) } } }