Skip to content

Commit d5d6e66

Browse files
author
Marcelo Vanzin
committed
Fix tests.
1 parent ec06218 commit d5d6e66

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

core/src/test/scala/org/apache/spark/ui/storage/StorageTabSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ class StorageTabSuite extends FunSuite with BeforeAndAfter {
175175
val block1 = (RDDBlockId(1, 1), BlockStatus(memOnly, 200L, 0L, 0L))
176176
taskMetrics0.updatedBlocks = Some(Seq(block0))
177177
taskMetrics1.updatedBlocks = Some(Seq(block1))
178-
bus.postToAll(SparkListenerBlockManagerAdded(bm1, 1000L))
178+
bus.postToAll(SparkListenerBlockManagerAdded(1L, bm1, 1000L))
179179
bus.postToAll(SparkListenerStageSubmitted(stageInfo0))
180180
assert(storageListener.rddInfoList.size === 0)
181181
bus.postToAll(SparkListenerTaskEnd(0, 0, "big", Success, taskInfo, taskMetrics0))

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -157,9 +157,9 @@ class JsonProtocolSuite extends FunSuite {
157157
test("BlockManager events backward compatibility") {
158158
// SparkListenerBlockManagerAdded/Removed in Spark 1.0.0 do not have a "time" property.
159159
val blockManagerAdded = SparkListenerBlockManagerAdded(1L,
160-
BlockManagerId("Stars", "In your multitude...", 300, 400), 500)
160+
BlockManagerId("Stars", "In your multitude...", 300), 500)
161161
val blockManagerRemoved = SparkListenerBlockManagerRemoved(2L,
162-
BlockManagerId("Scarce", "to be counted...", 100, 200))
162+
BlockManagerId("Scarce", "to be counted...", 100))
163163

164164
val oldBmAdded = JsonProtocol.blockManagerAddedToJson(blockManagerAdded)
165165
.removeField({ _._1 == "Timestamp" })

0 commit comments

Comments
 (0)