ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-22076][SQL][FOLLOWUP] Expand.projections should not be a Stream

Browse source 
## What changes were proposed in this pull request?

This a follow-up of https://github.com/apache/spark/pull/19289 , we missed another place: `rollup`. `Seq.init.toSeq` also returns a `Stream`, we should fix it too.

## How was this patch tested?

manually

Author: Wenchen Fan <wenchen@databricks.com>

Closes #19298 from cloud-fan/bug.
This commit is contained in:
Wenchen Fan 2017-09-20 21:13:46 -07:00 committed by gatorsmile
parent 55d5fa79db
commit 352bea5457
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
View file

@ -268,7 +268,7 @@ class Analyzer(
* We need to get all of its subsets for the rule described above, the subset is * We need to get all of its subsets for the rule described above, the subset is
* represented as sequence of expressions. * 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 * GROUP BY a, b, c WITH CUBE