diff --git a/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterSchedulerBackend.scala b/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterSchedulerBackend.scala index 5799df94ede24..3728c33228d23 100644 --- a/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterSchedulerBackend.scala +++ b/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterSchedulerBackend.scala @@ -37,6 +37,7 @@ private[spark] class YarnClusterSchedulerBackend( override def stop(exitCode: Int): Unit = { yarnSchedulerEndpoint.signalDriverStop(exitCode) + super.stop() } override def getDriverLogUrls: Option[Map[String, String]] = {