Skip to content

Commit

Permalink
[SPARK-5132][Core]Correct stage Attempt Id key in stageInfofromJson
Browse files Browse the repository at this point in the history
SPARK-5132:
stageInfoToJson: Stage Attempt Id
stageInfoFromJson: Attempt Id

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

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

41419ab [hushan[胡珊]] Correct stage Attempt Id key in stageInfofromJson
  • Loading branch information
suyanNone authored and JoshRosen committed Jan 7, 2015
1 parent 60e2d9e commit d345ebe
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -530,7 +530,7 @@ private[spark] object JsonProtocol {

def stageInfoFromJson(json: JValue): StageInfo = {
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 numTasks = (json \ "Number of Tasks").extract[Int]
val rddInfos = (json \ "RDD Info").extract[List[JValue]].map(rddInfoFromJson(_))
Expand Down

0 comments on commit d345ebe

Please sign in to comment.