From ae70876219873203bb9f0f1c248a5a6ee97af8d3 Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Tue, 10 Nov 2015 14:40:19 -0800 Subject: [PATCH] [SPARK-11641][SQL] Exchange plan string is too verbose --- .../org/apache/spark/sql/execution/Exchange.scala | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala index a4ce328c1a9eb..a6ea1a6f7a8ff 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala @@ -43,15 +43,13 @@ case class Exchange( override def nodeName: String = { val extraInfo = coordinator match { - case Some(exchangeCoordinator) if exchangeCoordinator.isEstimated => - "Shuffle" - case Some(exchangeCoordinator) if !exchangeCoordinator.isEstimated => - "May shuffle" - case None => "Shuffle without coordinator" + case Some(exchangeCoordinator) if exchangeCoordinator.isEstimated => "(Shuffle)" + case Some(exchangeCoordinator) if !exchangeCoordinator.isEstimated => "(May shuffle)" + case None => "" } val simpleNodeName = if (tungstenMode) "TungstenExchange" else "Exchange" - s"$simpleNodeName($extraInfo)" + s"$simpleNodeName$extraInfo" } /**