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 8f9c0417ed..0d8bd3baec 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 @@ -684,10 +684,7 @@ private[celeborn] class Master( workersToAdd: util.List[WorkerInfo], workersToRemove: util.List[WorkerInfo], requestId: String): Unit = { - statusSystem.handleWorkerExclude( - workersToAdd.asScala.filter(workersSnapShot.contains(_)).asJava, - workersToRemove.asScala.filter(workersSnapShot.contains(_)).asJava, - requestId) + statusSystem.handleWorkerExclude(workersToAdd, workersToRemove, requestId) if (context != null) { context.reply(WorkerExcludeResponse(true)) }