File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
core/src/main/scala/org/apache/spark/util Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -25,6 +25,8 @@ import scala.collection.Map
2525import org .json4s .DefaultFormats
2626import org .json4s .JsonDSL ._
2727import org .json4s .JsonAST ._
28+
29+ // Don't remove. It may seem this statement is useless but this is need to parse with Jackson
2830import org .json4s .jackson .JsonMethods ._
2931
3032
@@ -217,7 +219,7 @@ private[spark] object JsonProtocol {
217219 (" Getting Result Time" -> taskInfo.gettingResultTime) ~
218220 (" Finish Time" -> taskInfo.finishTime) ~
219221 (" Failed" -> taskInfo.failed) ~
220- (" Accumulables" -> JArray (taskInfo.accumulables .map(accumulableInfoToJson).toList))
222+ (" Accumulables" -> JArray (accumUpdateMap .map(accumulableInfoToJson).toList))
221223 }
222224
223225 def accumulableInfoToJson (accumulableInfo : AccumulableInfo ): JValue = {
You can’t perform that action at this time.
0 commit comments