aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKousuke Saruta <sarutak@oss.nttdata.co.jp>2014-09-15 16:11:41 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-09-15 16:11:41 -0700
commite59fac1f97c3fbeeb6defd12625a49763a353156 (patch)
tree0aa57d2bdeb7edf0f0f154a1afb371546743c13d
parentfe2b1d6a209db9fe96b1c6630677955b94bd48c9 (diff)
downloadspark-e59fac1f97c3fbeeb6defd12625a49763a353156.tar.gz
spark-e59fac1f97c3fbeeb6defd12625a49763a353156.tar.bz2
spark-e59fac1f97c3fbeeb6defd12625a49763a353156.zip
[SPARK-3518] Remove wasted statement in JsonProtocol
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp> Closes #2380 from sarutak/SPARK-3518 and squashes the following commits: 8a1464e [Kousuke Saruta] Replaced a variable with simple field reference c660fbc [Kousuke Saruta] Removed useless statement in JsonProtocol.scala
-rw-r--r--core/src/main/scala/org/apache/spark/util/JsonProtocol.scala1
1 files changed, 0 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/JsonProtocol.scala b/core/src/main/scala/org/apache/spark/util/JsonProtocol.scala
index b0754e3ce1..c4dddb2d10 100644
--- a/core/src/main/scala/org/apache/spark/util/JsonProtocol.scala
+++ b/core/src/main/scala/org/apache/spark/util/JsonProtocol.scala
@@ -205,7 +205,6 @@ private[spark] object JsonProtocol {
}
def taskInfoToJson(taskInfo: TaskInfo): JValue = {
- val accumUpdateMap = taskInfo.accumulables
("Task ID" -> taskInfo.taskId) ~
("Index" -> taskInfo.index) ~
("Attempt" -> taskInfo.attempt) ~