Skip to content

Commit

Permalink
Removed useless statement in JsonProtocol.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
sarutak committed Sep 13, 2014
1 parent b4dded4 commit c660fbc
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion core/src/main/scala/org/apache/spark/util/JsonProtocol.scala
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@ import scala.collection.Map
import org.json4s.DefaultFormats
import org.json4s.JsonDSL._
import org.json4s.JsonAST._

// Don't remove. It may seem this statement is useless but this is need to parse with Jackson
import org.json4s.jackson.JsonMethods._


Expand Down Expand Up @@ -217,7 +219,7 @@ private[spark] object JsonProtocol {
("Getting Result Time" -> taskInfo.gettingResultTime) ~
("Finish Time" -> taskInfo.finishTime) ~
("Failed" -> taskInfo.failed) ~
("Accumulables" -> JArray(taskInfo.accumulables.map(accumulableInfoToJson).toList))
("Accumulables" -> JArray(accumUpdateMap.map(accumulableInfoToJson).toList))
}

def accumulableInfoToJson(accumulableInfo: AccumulableInfo): JValue = {
Expand Down

0 comments on commit c660fbc

Please sign in to comment.