Skip to content
Snippets Groups Projects
Commit 951024fe authored by Reynold Xin's avatar Reynold Xin
Browse files

Merge pull request #145 from aarondav/sls-fix

Attempt to fix SparkListenerSuite breakage

Could not reproduce locally, but this test could've been flaky if the build machine was too fast, due to typo. (index 0 is intentionally slowed down to ensure total time is >= 1 ms)

This should be merged into branch-0.8 as well.
parents bf4e6131 80e98d2b
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