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.fe...@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.fe...@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-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org