diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala index 714b78a11..351ff56f4 100644 --- a/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala +++ b/master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala @@ -464,11 +464,9 @@ private[celeborn] class Master( if (worker == null) { logWarning(s"Unknown worker $host:$rpcPort:$pushPort:$fetchPort:$replicatePort" + s" for WorkerLost handler!") - return + } else { + statusSystem.handleWorkerLost(host, rpcPort, pushPort, fetchPort, replicatePort, requestId) } - - statusSystem.handleWorkerLost(host, rpcPort, pushPort, fetchPort, replicatePort, requestId) - if (context != null) { context.reply(WorkerLostResponse(true)) }