natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'dev' into dev

This commit is contained in:
Aaron Wang 2024-04-26 11:35:11 +08:00 committed by GitHub
parent 27b847dc8f b29965bdce
commit 8e0dbe2a3e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
View File

@ -245,7 +245,7 @@ public class ServerNodeManager implements InitializingBean {
}
private void updateWorkerNodes() {
workerGroupWriteLock.lock();
workerNodeInfoWriteLock.lock();
try {
Map<String, String> workerNodeMaps = registryClient.getServerMaps(RegistryNodeType.WORKER);
for (Map.Entry<String, String> entry : workerNodeMaps.entrySet()) {
@ -254,7 +254,7 @@ public class ServerNodeManager implements InitializingBean {
workerNodeInfo.put(nodeAddress, workerHeartBeat);
}
} finally {
workerGroupWriteLock.unlock();
workerNodeInfoWriteLock.unlock();
}
}