Skip to content
Snippets Groups Projects
Commit 80e98d2b authored by Aaron Davidson's avatar Aaron Davidson
Browse files

Attempt to fix SparkListenerSuite breakage

Could not reproduce locally, but this test could've been flaky if the
build machine was too fast.
parent bf4e6131
No related branches found
No related tags found
No related merge requests found
......@@ -83,7 +83,7 @@ class SparkListenerSuite extends FunSuite with LocalSparkContext with ShouldMatc
i
}
val d = sc.parallelize(1 to 1e4.toInt, 64).map{i => w(i)}
val d = sc.parallelize(0 to 1e4.toInt, 64).map{i => w(i)}
d.count()
assert(sc.dagScheduler.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS))
listener.stageInfos.size should be (1)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment