Skip to content

Commit d345ebe

Browse files
suyanNoneJoshRosen
authored andcommitted
[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
1 parent 60e2d9e commit d345ebe

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/util/JsonProtocol.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -530,7 +530,7 @@ private[spark] object JsonProtocol {
530530

531531
def stageInfoFromJson(json: JValue): StageInfo = {
532532
val stageId = (json \ "Stage ID").extract[Int]
533-
val attemptId = (json \ "Attempt ID").extractOpt[Int].getOrElse(0)
533+
val attemptId = (json \ "Stage Attempt ID").extractOpt[Int].getOrElse(0)
534534
val stageName = (json \ "Stage Name").extract[String]
535535
val numTasks = (json \ "Number of Tasks").extract[Int]
536536
val rddInfos = (json \ "RDD Info").extract[List[JValue]].map(rddInfoFromJson(_))

0 commit comments

Comments
 (0)