You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by li...@apache.org on 2017/09/21 04:13:50 UTC
spark git commit: [SPARK-22076][SQL][FOLLOWUP] Expand.projections
should not be a Stream
Repository: spark
Updated Branches:
refs/heads/master 55d5fa79d -> 352bea545
[SPARK-22076][SQL][FOLLOWUP] Expand.projections should not be a Stream
## 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 <we...@databricks.com>
Closes #19298 from cloud-fan/bug.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/352bea54
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/352bea54
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/352bea54
Branch: refs/heads/master
Commit: 352bea5457bf77bb6d0e45a8c71be104bee8a586
Parents: 55d5fa7
Author: Wenchen Fan <we...@databricks.com>
Authored: Wed Sep 20 21:13:46 2017 -0700
Committer: gatorsmile <ga...@gmail.com>
Committed: Wed Sep 20 21:13:46 2017 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/352bea54/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
----------------------------------------------------------------------
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 4535176..45ec204 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
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org