diff --git a/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala b/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala index c625fae8e6736..52a6e5b7797f2 100644 --- a/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala +++ b/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala @@ -1309,7 +1309,8 @@ class AppStatusListenerSuite extends SparkFunSuite with BeforeAndAfter { stage.failureReason = Some("Failed") listener.onStageCompleted(SparkListenerStageCompleted(stage)) time += 1 - listener.onJobEnd(SparkListenerJobEnd(1, time, JobFailed(new RuntimeException("Bad Executor")))) + listener.onJobEnd(SparkListenerJobEnd(1, time, JobFailed( + new RuntimeException("Bad Executor")))) time += 1 tasks(2).markFinished(TaskState.FAILED, time)