diff --git a/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala b/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala index a647bb4f3d..cb0de5a0d5 100644 --- a/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala +++ b/resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala @@ -164,7 +164,7 @@ private[spark] class YarnClientSchedulerBackend( super.stop() client.stop() - logInfo("Stopped") + logInfo("YARN client scheduler backend Stopped") } override protected def updateDelegationTokens(tokens: Array[Byte]): Unit = {