Skip to content
Snippets Groups Projects
Commit d345ebeb authored by hushan[胡珊]'s avatar hushan[胡珊] Committed by Josh Rosen
Browse files

[SPARK-5132][Core]Correct stage Attempt Id key in stageInfofromJson

SPARK-5132:
stageInfoToJson: Stage Attempt Id
stageInfoFromJson: Attempt Id

Author: hushan[胡珊] <hushan@xiaomi.com>

Closes #3932 from suyanNone/json-stage and squashes the following commits:

41419ab [hushan[胡珊]] Correct stage Attempt Id key in stageInfofromJson
parent 60e2d9e2
No related branches found
No related tags found
No related merge requests found
...@@ -530,7 +530,7 @@ private[spark] object JsonProtocol { ...@@ -530,7 +530,7 @@ private[spark] object JsonProtocol {
def stageInfoFromJson(json: JValue): StageInfo = { def stageInfoFromJson(json: JValue): StageInfo = {
val stageId = (json \ "Stage ID").extract[Int] val stageId = (json \ "Stage ID").extract[Int]
val attemptId = (json \ "Attempt ID").extractOpt[Int].getOrElse(0) val attemptId = (json \ "Stage Attempt ID").extractOpt[Int].getOrElse(0)
val stageName = (json \ "Stage Name").extract[String] val stageName = (json \ "Stage Name").extract[String]
val numTasks = (json \ "Number of Tasks").extract[Int] val numTasks = (json \ "Number of Tasks").extract[Int]
val rddInfos = (json \ "RDD Info").extract[List[JValue]].map(rddInfoFromJson(_)) val rddInfos = (json \ "RDD Info").extract[List[JValue]].map(rddInfoFromJson(_))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment