diff --git a/core/src/test/scala/org/apache/spark/DistributedSuite.scala b/core/src/test/scala/org/apache/spark/DistributedSuite.scala index 27c4b017997bc6213897454c74d8f17ec3cf0264..8de7a328d1cf5eadd5f46ecf470ebd109e660186 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] {