spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject spark git commit: [MINOR][SQL] The comment of Class ExchangeCoordinator exist a typing and context error
Date Thu, 24 Aug 2017 09:07:30 GMT
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.fei80@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.fei80@zte.com.cn>
Authored: Thu Aug 24 10:07:27 2017 +0100
Committer: Sean Owen <sowen@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


Mime
View raw message