From aa263d7b16630ad134e80fbf68a42165667446b5 Mon Sep 17 00:00:00 2001 From: Wenchen Fan Date: Thu, 21 Sep 2017 08:12:25 +0800 Subject: [PATCH] Expand.projections should not be a Stream --- .../scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 4535176a14d89..45ec2045de9a9 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 @@ -268,7 +268,7 @@ class Analyzer( * We need to get all of its subsets for the rule described above, the subset is * represented as sequence of expressions. */ - def rollupExprs(exprs: Seq[Expression]): Seq[Seq[Expression]] = exprs.inits.toSeq + def rollupExprs(exprs: Seq[Expression]): Seq[Seq[Expression]] = exprs.inits.toIndexedSeq /* * GROUP BY a, b, c WITH CUBE