diff options
| author | root <root@iZbp1gsnrlfzjxh82cz80vZ.(none)> | 2016-11-17 17:04:19 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-11-17 17:04:19 +0000 |
| commit | b0aa1aa1af6c513a6a881eaea96abdd2b480ef98 (patch) | |
| tree | b7a0a57cd6b2a0be8ed12f3a08ec2e998571ebde | |
| parent | cdaf4ce9fe58c4606be8aa2a5c3756d30545c850 (diff) | |
| download | spark-b0aa1aa1af6c513a6a881eaea96abdd2b480ef98.tar.gz spark-b0aa1aa1af6c513a6a881eaea96abdd2b480ef98.tar.bz2 spark-b0aa1aa1af6c513a6a881eaea96abdd2b480ef98.zip | |
[SPARK-18490][SQL] duplication nodename extrainfo for ShuffleExchange
## What changes were proposed in this pull request?
In ShuffleExchange, the nodename's extraInfo are the same when exchangeCoordinator.isEstimated
is true or false.
Merge the two situation in the PR.
Author: root <root@iZbp1gsnrlfzjxh82cz80vZ.(none)>
Closes #15920 from windpiger/DupNodeNameShuffleExchange.
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala index 7a4a251370..125a4930c6 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala @@ -45,9 +45,7 @@ case class ShuffleExchange( override def nodeName: String = { val extraInfo = coordinator match { - case Some(exchangeCoordinator) if exchangeCoordinator.isEstimated => - s"(coordinator id: ${System.identityHashCode(coordinator)})" - case Some(exchangeCoordinator) if !exchangeCoordinator.isEstimated => + case Some(exchangeCoordinator) => s"(coordinator id: ${System.identityHashCode(coordinator)})" case None => "" } |