Skip to content
Snippets Groups Projects
Unverified Commit 97879888 authored by root's avatar root Committed by Sean Owen
Browse files

[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.

(cherry picked from commit b0aa1aa1)
Signed-off-by: default avatarSean Owen <sowen@cloudera.com>
parent 536a2159
No related branches found
No related tags found
No related merge requests found
......@@ -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 => ""
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment