@@ -302,7 +302,7 @@ private[spark] class Master(
302302 exec.application.driver ! ExecutorUpdated (execId, state, message, exitStatus)
303303 if (ExecutorState .isFinished(state)) {
304304 // Remove this executor from the worker and app
305- logInfo(" Removing executor " + exec.fullId + " because it is " + state)
305+ logInfo(s " Removing executor ${ exec.fullId} because it is $ state" )
306306 appInfo.removeExecutor(exec)
307307 exec.worker.removeExecutor(exec)
308308
@@ -312,8 +312,8 @@ private[spark] class Master(
312312 if (appInfo.incrementRetryCount() < ApplicationState .MAX_NUM_RETRY ) {
313313 schedule()
314314 } else {
315- logError(" Application %s with ID %s failed %d times, removing it " .format(
316- appInfo.desc.name, appInfo.id, appInfo.retryCount) )
315+ logError(s " Application ${appInfo.desc.name} with ID ${appInfo.id} failed " +
316+ s " ${ appInfo.retryCount} times; removing it " )
317317 val execs = idToApp(appId).executors.values
318318 if (! execs.exists(_.state == ExecutorState .RUNNING )) {
319319 removeApplication(appInfo, ApplicationState .FAILED )
@@ -323,7 +323,7 @@ private[spark] class Master(
323323 }
324324 }
325325 case None =>
326- logWarning(" Got status update for unknown executor " + appId + " / " + execId)
326+ logWarning(s " Got status update for unknown executor $ appId/ $ execId" )
327327 }
328328 }
329329
0 commit comments