You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2017/08/24 09:07:30 UTC
spark git commit: [MINOR][SQL] The comment of Class
ExchangeCoordinator exist a typing and context error
Repository: spark
Updated Branches:
refs/heads/master ce0d3bb37 -> 846bc61cf
[MINOR][SQL] The comment of Class ExchangeCoordinator exist a typing and context error
## What changes were proposed in this pull request?
The given example in the comment of Class ExchangeCoordinator is exist four post-shuffle partitions,but the current comment is “three”.
## How was this patch tested?
Author: lufei <lu...@zte.com.cn>
Closes #19028 from figo77/SPARK-21816.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/846bc61c
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/846bc61c
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/846bc61c
Branch: refs/heads/master
Commit: 846bc61cf5aa522dc755d50359ef3856ef2b17bf
Parents: ce0d3bb
Author: lufei <lu...@zte.com.cn>
Authored: Thu Aug 24 10:07:27 2017 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Thu Aug 24 10:07:27 2017 +0100
----------------------------------------------------------------------
.../apache/spark/sql/execution/exchange/ExchangeCoordinator.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/846bc61c/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala
index deb2c24..9fc4ffb 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ExchangeCoordinator.scala
@@ -75,7 +75,7 @@ import org.apache.spark.sql.execution.{ShuffledRowRDD, SparkPlan}
* For example, we have two stages with the following pre-shuffle partition size statistics:
* stage 1: [100 MB, 20 MB, 100 MB, 10MB, 30 MB]
* stage 2: [10 MB, 10 MB, 70 MB, 5 MB, 5 MB]
- * assuming the target input size is 128 MB, we will have three post-shuffle partitions,
+ * assuming the target input size is 128 MB, we will have four post-shuffle partitions,
* which are:
* - post-shuffle partition 0: pre-shuffle partition 0 (size 110 MB)
* - post-shuffle partition 1: pre-shuffle partition 1 (size 30 MB)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org