(dolphinscheduler) branch dev updated: [Fix-17408] Don't filter out inactive worker addresses in onWorkerGroupChange (#17412)

[wenjun]

This is an automated email from the ASF dual-hosted git repository.

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0abc08fe4a [Fix-17408] Don't filter out inactive worker addresses in 
onWorkerGroupChange (#17412)
0abc08fe4a is described below

commit 0abc08fe4afae4854f95bb89ac889c6671f21164
Author: lile <38578667+re...@users.noreply.github.com>
AuthorDate: Thu Aug 14 15:26:24 2025 +0800

    [Fix-17408] Don't filter out inactive worker addresses in 
onWorkerGroupChange (#17412)
---
 .../dolphinscheduler/server/master/cluster/WorkerClusters.java   | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster/WorkerClusters.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster/WorkerClusters.java
index 1716e78b07..c94d8861de 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster/WorkerClusters.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster/WorkerClusters.java
@@ -126,14 +126,9 @@ public class WorkerClusters extends 
AbstractClusterSubscribeListener<WorkerServe
     @Override
     public void onWorkerGroupChange(List<WorkerGroup> workerGroups) {
         for (WorkerGroup workerGroup : workerGroups) {
-            List<String> activeWorkers = 
WorkerGroupUtils.getWorkerAddressListFromWorkerGroup(workerGroup)
-                    .stream()
-                    .map(workerMapping::get)
-                    .filter(Objects::nonNull)
-                    .map(WorkerServerMetadata::getAddress)
-                    .collect(Collectors.toList());
+            List<String> workerAddresses = 
WorkerGroupUtils.getWorkerAddressListFromWorkerGroup(workerGroup);
             synchronized (dbWorkerGroupMapping) {
-                dbWorkerGroupMapping.put(workerGroup.getName(), activeWorkers);
+                dbWorkerGroupMapping.put(workerGroup.getName(), 
workerAddresses);
             }
         }
     }