Skip to content
Snippets Groups Projects
Commit 718a13c1 authored by Kay Ousterhout's avatar Kay Ousterhout
Browse files

Updated unit test comment

parent a268d634
No related branches found
No related tags found
No related merge requests found
......@@ -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] {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment