Skip to content

Commit e89b2f6

Browse files
committed
Fixed Json tests.
1 parent 7af424c commit e89b2f6

File tree

1 file changed

+6
-8
lines changed

1 file changed

+6
-8
lines changed

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

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -538,9 +538,8 @@ class JsonProtocolSuite extends FunSuite {
538538
private val stageSubmittedJsonString =
539539
"""
540540
{"Event":"SparkListenerStageSubmitted","Stage Info":{"Stage ID":100,"Stage Name":
541-
"greetings","Number of Tasks":200,"RDD Info":[],"Details":"details",
542-
"Emitted Task Size Warning":false},"Properties":{"France":"Paris","Germany":"Berlin",
543-
"Russia":"Moscow","Ukraine":"Kiev"}}
541+
"greetings","Number of Tasks":200,"RDD Info":[],"Details":"details"},"Properties":
542+
{"France":"Paris","Germany":"Berlin","Russia":"Moscow","Ukraine":"Kiev"}}
544543
"""
545544

546545
private val stageCompletedJsonString =
@@ -549,24 +548,23 @@ class JsonProtocolSuite extends FunSuite {
549548
"greetings","Number of Tasks":201,"RDD Info":[{"RDD ID":101,"Name":"mayor","Storage
550549
Level":{"Use Disk":true,"Use Memory":true,"Use Tachyon":false,"Deserialized":true,
551550
"Replication":1},"Number of Partitions":201,"Number of Cached Partitions":301,
552-
"Memory Size":401,"Tachyon Size":0,"Disk Size":501}],"Details":"details",
553-
"Emitted Task Size Warning":false}}
551+
"Memory Size":401,"Tachyon Size":0,"Disk Size":501}],"Details":"details"}}
554552
"""
555553

556554
private val taskStartJsonString =
557555
"""
558556
|{"Event":"SparkListenerTaskStart","Stage ID":111,"Task Info":{"Task ID":222,
559557
|"Index":333,"Attempt":1,"Launch Time":444,"Executor ID":"executor","Host":"your kind sir",
560558
|"Locality":"NODE_LOCAL","Speculative":false,"Getting Result Time":0,"Finish Time":0,
561-
|"Failed":false,"Serialized Size":0}}
559+
|"Failed":false}}
562560
""".stripMargin
563561

564562
private val taskGettingResultJsonString =
565563
"""
566564
|{"Event":"SparkListenerTaskGettingResult","Task Info":
567565
| {"Task ID":1000,"Index":2000,"Attempt":5,"Launch Time":3000,"Executor ID":"executor",
568566
| "Host":"your kind sir","Locality":"NODE_LOCAL","Speculative":true,"Getting Result Time":0,
569-
| "Finish Time":0,"Failed":false,"Serialized Size":0
567+
| "Finish Time":0,"Failed":false
570568
| }
571569
|}
572570
""".stripMargin
@@ -578,7 +576,7 @@ class JsonProtocolSuite extends FunSuite {
578576
|"Task Info":{
579577
| "Task ID":123,"Index":234,"Attempt":67,"Launch Time":345,"Executor ID":"executor",
580578
| "Host":"your kind sir","Locality":"NODE_LOCAL","Speculative":false,
581-
| "Getting Result Time":0,"Finish Time":0,"Failed":false,"Serialized Size":0
579+
| "Getting Result Time":0,"Finish Time":0,"Failed":false
582580
|},
583581
|"Task Metrics":{
584582
| "Host Name":"localhost","Executor Deserialize Time":300,"Executor Run Time":400,

0 commit comments

Comments
 (0)