diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-05 17:56:50 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-05 17:56:50 -0600 |
| commit | 1ba3393ceb5709620a28b8bc01826153993fc444 (patch) | |
| tree | 50f1316e3d8913675537774dd36e49d3e4673499 | |
| parent | ae26911ec0d768dcdae8b7d706ca4544e36535e6 (diff) | |
| download | spark-1ba3393ceb5709620a28b8bc01826153993fc444.tar.gz spark-1ba3393ceb5709620a28b8bc01826153993fc444.tar.bz2 spark-1ba3393ceb5709620a28b8bc01826153993fc444.zip | |
Increase DriverSuite timeout.
| -rw-r--r-- | core/src/test/scala/spark/DriverSuite.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/test/scala/spark/DriverSuite.scala b/core/src/test/scala/spark/DriverSuite.scala index 342610e1dd..5e84b3a66a 100644 --- a/core/src/test/scala/spark/DriverSuite.scala +++ b/core/src/test/scala/spark/DriverSuite.scala @@ -9,10 +9,11 @@ import org.scalatest.time.SpanSugar._ class DriverSuite extends FunSuite with Timeouts { test("driver should exit after finishing") { + assert(System.getenv("SPARK_HOME") != null) // Regression test for SPARK-530: "Spark driver process doesn't exit after finishing" val masters = Table(("master"), ("local"), ("local-cluster[2,1,512]")) forAll(masters) { (master: String) => - failAfter(10 seconds) { + failAfter(30 seconds) { Utils.execute(Seq("./run", "spark.DriverWithoutCleanup", master), new File(System.getenv("SPARK_HOME"))) } |