Skip to content

Commit 9f18bad

Browse files
committed
Minor style changes and tests
1 parent 7a63abc commit 9f18bad

File tree

3 files changed

+16
-7
lines changed

3 files changed

+16
-7
lines changed

core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ class JobProgressListener(conf: SparkConf) extends SparkListener {
7676
poolToActiveStages(stageIdToPool(stageId)).remove(stageId)
7777

7878
val accumulables = stageIdToAccumulables.getOrElseUpdate(stageId, HashMap[String, String]())
79-
stageCompleted.stageInfo.accumulatedValues.foreach { case (name, value) =>
79+
for ((name, value) <- stageCompleted.stageInfo.accumulatedValues) {
8080
accumulables(name) = value
8181
}
8282

@@ -156,7 +156,7 @@ class JobProgressListener(conf: SparkConf) extends SparkListener {
156156

157157
if (info != null) {
158158
val accumulables = stageIdToAccumulables.getOrElseUpdate(sid, HashMap[String, String]())
159-
info.accumulableValues.map { case (name, value) =>
159+
for ((name, value) <- info.accumulableValues) {
160160
accumulables(name) = value
161161
}
162162

core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,9 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
290290
<td sorttable_customkey={gcTime.toString}>
291291
{if (gcTime > 0) UIUtils.formatDuration(gcTime) else ""}
292292
</td>
293-
<td>{Unparsed(info.accumulableValues.map{ case (k, v) => s"$k: $v" }.mkString("<br/>"))}</td>
293+
<td>
294+
{Unparsed(info.accumulableValues.map{ case (k, v) => s"$k: $v" }.mkString("<br/>"))}
295+
</td>
294296
<!--
295297
TODO: Add this back after we add support to hide certain columns.
296298
<td sorttable_customkey={serializationTime.toString}>

core/src/test/scala/org/apache/spark/util/JsonProtocolSuite.scala

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -123,15 +123,22 @@ class JsonProtocolSuite extends FunSuite {
123123
testBlockId(StreamBlockId(1, 2L))
124124
}
125125

126-
test("StageInfo.details backward compatibility") {
127-
// StageInfo.details was added after 1.0.0.
126+
test("StageInfo backward compatibility") {
128127
val info = makeStageInfo(1, 2, 3, 4L, 5L)
129-
assert(info.details.nonEmpty)
130128
val newJson = JsonProtocol.stageInfoToJson(info)
131-
val oldJson = newJson.removeField { case (field, _) => field == "Details" }
129+
130+
// Fields added after 1.0.0.
131+
assert(info.details.nonEmpty)
132+
assert(info.accumulatedValues.nonEmpty)
133+
val oldJson = newJson
134+
.removeField { case (field, _) => field == "Details" }
135+
.removeField { case (field, _) => field == "Accumulated Values" }
136+
132137
val newInfo = JsonProtocol.stageInfoFromJson(oldJson)
138+
133139
assert(info.name === newInfo.name)
134140
assert("" === newInfo.details)
141+
assert(0 === newInfo.accumulatedValues.size)
135142
}
136143

137144
test("InputMetrics backward compatibility") {

0 commit comments

Comments
 (0)