Skip to content

Commit 55a0e87

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 apache#1037 from ankurdave/bagel-test-time-limit and squashes the following commits: 67fd487 [Ankur Dave] Increase time limit for Bagel test
1 parent fb499be commit 55a0e87

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
@@ -80,7 +80,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo
8080
test("large number of iterations") {
8181
// This tests whether jobs with a large number of iterations finish in a reasonable time,
8282
// because non-memoized recursion in RDD or DAGScheduler used to cause them to hang
83-
failAfter(10 seconds) {
83+
failAfter(30 seconds) {
8484
sc = new SparkContext("local", "test")
8585
val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0))))
8686
val msgs = sc.parallelize(Array[(String, TestMessage)]())
@@ -101,7 +101,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo
101101
sc = new SparkContext("local", "test")
102102
val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0))))
103103
val msgs = sc.parallelize(Array[(String, TestMessage)]())
104-
val numSupersteps = 50
104+
val numSupersteps = 20
105105
val result =
106106
Bagel.run(sc, verts, msgs, sc.defaultParallelism, StorageLevel.DISK_ONLY) {
107107
(self: TestVertex, msgs: Option[Array[TestMessage]], superstep: Int) =>

0 commit comments

Comments
 (0)