diff --git a/core/src/main/scala/org/apache/spark/deploy/Client.scala b/core/src/main/scala/org/apache/spark/deploy/Client.scala index 7c5ab43a9e1b3..2f1ff54358d82 100644 --- a/core/src/main/scala/org/apache/spark/deploy/Client.scala +++ b/core/src/main/scala/org/apache/spark/deploy/Client.scala @@ -190,13 +190,15 @@ private class ClientEndpoint( logDebug(s"State of driver $submittedDriverID is ${state.get}, " + s"continue monitoring driver status.") } - } - } - } else { + } + } + } else if (exception.exists(e => Utils.responseFromBackup(e.getMessage))) { + logDebug(s"The status response is reported from a backup spark instance. So, ignored.") + } else { logError(s"ERROR: Cluster master did not recognize $submittedDriverID") System.exit(-1) - } } + } override def receive: PartialFunction[Any, Unit] = { case SubmitDriverResponse(master, success, driverId, message) =>