diff options
author | Ankur Dave <ankurdave@gmail.com> | 2014-06-10 13:15:06 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-06-10 13:15:11 -0700 |
commit | 55a0e87ee4655106d5e0ed799b11e77f68a17dbb (patch) | |
tree | 9ea5753f2a2d22f4ee53476c667dfc1e6a1414cb /bagel/src/test/scala | |
parent | fb499be1ac935b6f91046ec8ff23ac1267c82342 (diff) | |
download | spark-55a0e87ee4655106d5e0ed799b11e77f68a17dbb.tar.gz spark-55a0e87ee4655106d5e0ed799b11e77f68a17dbb.tar.bz2 spark-55a0e87ee4655106d5e0ed799b11e77f68a17dbb.zip |
HOTFIX: Increase time limit for Bagel test
The test was timing out on some slow EC2 workers.
Author: Ankur Dave <ankurdave@gmail.com>
Closes #1037 from ankurdave/bagel-test-time-limit and squashes the following commits:
67fd487 [Ankur Dave] Increase time limit for Bagel test
Diffstat (limited to 'bagel/src/test/scala')
-rw-r--r-- | bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala b/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala index 110bd0a9a0..55241d33cd 100644 --- a/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala +++ b/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala @@ -80,7 +80,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo test("large number of iterations") { // This tests whether jobs with a large number of iterations finish in a reasonable time, // because non-memoized recursion in RDD or DAGScheduler used to cause them to hang - failAfter(10 seconds) { + failAfter(30 seconds) { sc = new SparkContext("local", "test") val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0)))) val msgs = sc.parallelize(Array[(String, TestMessage)]()) @@ -101,7 +101,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo sc = new SparkContext("local", "test") val verts = sc.parallelize((1 to 4).map(id => (id.toString, new TestVertex(true, 0)))) val msgs = sc.parallelize(Array[(String, TestMessage)]()) - val numSupersteps = 50 + val numSupersteps = 20 val result = Bagel.run(sc, verts, msgs, sc.defaultParallelism, StorageLevel.DISK_ONLY) { (self: TestVertex, msgs: Option[Array[TestMessage]], superstep: Int) => |