Skip to content

Commit 5bc186d

Browse files
ankurdavepwendell
authored andcommitted
HOTFIX: Increase time limit for Bagel test
The test was timing out on some slow EC2 workers. Author: Ankur Dave <[email protected]> Closes #1037 from ankurdave/bagel-test-time-limit and squashes the following commits: 67fd487 [Ankur Dave] Increase time limit for Bagel test (cherry picked from commit 55a0e87) Signed-off-by: Patrick Wendell <[email protected]>
1 parent 1d9b765 commit 5bc186d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo
8282
test("large number of iterations") {
8383
// This tests whether jobs with a large number of iterations finish in a reasonable time,
8484
// because non-memoized recursion in RDD or DAGScheduler used to cause them to hang
85-
failAfter(10 seconds) {
85+
failAfter(30 seconds) {
8686
sc = new SparkContext("local", "test")
8787
val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0))))
8888
val msgs = sc.parallelize(Array[(String, TestMessage)]())
@@ -103,7 +103,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo
103103
sc = new SparkContext("local", "test")
104104
val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0))))
105105
val msgs = sc.parallelize(Array[(String, TestMessage)]())
106-
val numSupersteps = 50
106+
val numSupersteps = 20
107107
val result =
108108
Bagel.run(sc, verts, msgs, sc.defaultParallelism, StorageLevel.DISK_ONLY) {
109109
(self: TestVertex, msgs: Option[Array[TestMessage]], superstep: Int) =>

0 commit comments

Comments
 (0)