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 <[email protected]>
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);
}
}
}