Skip to content

Commit 0abc08f

Browse files
authored
[Fix-17408] Don't filter out inactive worker addresses in onWorkerGroupChange (#17412)
1 parent 0a53544 commit 0abc08f

1 file changed

Lines changed: 2 additions & 7 deletions

File tree

  • dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cluster/WorkerClusters.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -126,14 +126,9 @@ public void onWorkerGroupAdd(List<WorkerGroup> workerGroups) {
126126
@Override
127127
public void onWorkerGroupChange(List<WorkerGroup> workerGroups) {
128128
for (WorkerGroup workerGroup : workerGroups) {
129-
List<String> activeWorkers = WorkerGroupUtils.getWorkerAddressListFromWorkerGroup(workerGroup)
130-
.stream()
131-
.map(workerMapping::get)
132-
.filter(Objects::nonNull)
133-
.map(WorkerServerMetadata::getAddress)
134-
.collect(Collectors.toList());
129+
List<String> workerAddresses = WorkerGroupUtils.getWorkerAddressListFromWorkerGroup(workerGroup);
135130
synchronized (dbWorkerGroupMapping) {
136-
dbWorkerGroupMapping.put(workerGroup.getName(), activeWorkers);
131+
dbWorkerGroupMapping.put(workerGroup.getName(), workerAddresses);
137132
}
138133
}
139134
}

0 commit comments

Comments
 (0)