support with

jacek-lewandowski · Mar 3, 2015 · 1cc8c15 · 1cc8c15
1 parent 03f1097
commit 1cc8c15
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala
@@ -166,7 +166,7 @@ class SqlParser extends AbstractSparkSQLParser {
 
   protected lazy val cte: Parser[LogicalPlan] =
     WITH ~> rep1sep(ident ~ ( AS ~ "(" ~> start <~ ")"), ",") ~ start ^^ {
-      case r ~ s => With(s, r.map({case n ~ s => Subquery(n, s)}).toSeq)
+      case r ~ s => With(s, r.map({case n ~ s => (n, Subquery(n, s))}).toMap)
     }
 
   protected lazy val projection: Parser[Expression] =