File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -275,7 +275,8 @@ private[master] class Master(
275275
276276 case RequestKillDriver (driverId) => {
277277 if (state != RecoveryState .ALIVE ) {
278- val msg = s " ${Utils .BACKUP_STANDALONE_MASTER_PREFIX }: $state. Can only kill drivers in ALIVE state. "
278+ val msg = s " ${Utils .BACKUP_STANDALONE_MASTER_PREFIX }: $state. " +
279+ s " Can only kill drivers in ALIVE state. "
279280 sender ! KillDriverResponse (driverId, success = false , msg)
280281 } else {
281282 logInfo(" Asked to kill driver " + driverId)
Original file line number Diff line number Diff line change @@ -2119,7 +2119,7 @@ private[spark] object Utils extends Logging {
21192119
21202120 /** Return true if the response message is sent from a backup Master on standby. */
21212121 def responseFromBackup (msg : String ): Boolean = {
2122- message .startsWith(BACKUP_STANDALONE_MASTER_PREFIX )
2122+ msg .startsWith(BACKUP_STANDALONE_MASTER_PREFIX )
21232123 }
21242124}
21252125
You can’t perform that action at this time.
0 commit comments