diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2014-01-15 23:46:14 -0800 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2014-01-15 23:46:14 -0800 |
| commit | 718a13c179915767107bc20cd27d9480d069231c (patch) | |
| tree | 277dcf4ec39c09e6904ae5738d63e2b28c68bbf2 /core | |
| parent | a268d634113536f7aca11af23619b9713b5ef5de (diff) | |
| download | spark-718a13c179915767107bc20cd27d9480d069231c.tar.gz spark-718a13c179915767107bc20cd27d9480d069231c.tar.bz2 spark-718a13c179915767107bc20cd27d9480d069231c.zip | |
Updated unit test comment
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/DistributedSuite.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/test/scala/org/apache/spark/DistributedSuite.scala b/core/src/test/scala/org/apache/spark/DistributedSuite.scala index 27c4b01799..8de7a328d1 100644 --- a/core/src/test/scala/org/apache/spark/DistributedSuite.scala +++ b/core/src/test/scala/org/apache/spark/DistributedSuite.scala @@ -127,7 +127,9 @@ class DistributedSuite extends FunSuite with ShouldMatchers with BeforeAndAfter test("repeatedly failing task that crashes JVM") { // Ensures that if a task fails in a way that crashes the JVM, the job eventually fails rather - // than hanging. + // than hanging due to retrying the failed task infinitely many times (eventually the + // standalone scheduler will remove the application, causing the job to hang waiting to + // reconnect to the master). sc = new SparkContext(clusterUrl, "test") failAfter(Span(100000, Millis)) { val thrown = intercept[SparkException] { |