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
25
25
import org .json4s .DefaultFormats
26
26
import org .json4s .JsonDSL ._
27
27
import org .json4s .JsonAST ._
28
+
29
+ // Don't remove. It may seem this statement is useless but this is need to parse with Jackson
28
30
import org .json4s .jackson .JsonMethods ._
29
31
30
32
@@ -217,7 +219,7 @@ private[spark] object JsonProtocol {
217
219
(" Getting Result Time" -> taskInfo.gettingResultTime) ~
218
220
(" Finish Time" -> taskInfo.finishTime) ~
219
221
(" Failed" -> taskInfo.failed) ~
220
- (" Accumulables" -> JArray (taskInfo.accumulables .map(accumulableInfoToJson).toList))
222
+ (" Accumulables" -> JArray (accumUpdateMap .map(accumulableInfoToJson).toList))
221
223
}
222
224
223
225
def accumulableInfoToJson (accumulableInfo : AccumulableInfo ): JValue = {
You can’t perform that action at this time.
0 commit comments