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:23 -0700 |
| commit | 5bc186dc7dc6057ff10a4da84ab054ea32772bf3 (patch) | |
| tree | d5c8677236fd02406aa2758561edffb97366b817 | |
| parent | 1d9b7651e42a33dd27d8c7a470f12b7cb6c14385 (diff) | |
| download | spark-5bc186dc7dc6057ff10a4da84ab054ea32772bf3.tar.gz spark-5bc186dc7dc6057ff10a4da84ab054ea32772bf3.tar.bz2 spark-5bc186dc7dc6057ff10a4da84ab054ea32772bf3.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
(cherry picked from commit 55a0e87ee4655106d5e0ed799b11e77f68a17dbb)
Signed-off-by: Patrick Wendell <pwendell@gmail.com>
| -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 8e0f82ddb8..9cea9a64cf 100644 --- a/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala +++ b/bagel/src/test/scala/org/apache/spark/bagel/BagelSuite.scala @@ -82,7 +82,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)]()) @@ -103,7 +103,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) => |