(dolphinscheduler) branch dev updated: [Fix] In updateWorkerNodes method, the workerNodeInfoWriteLock should be used. #15898 (#15903)

[weiraowang]

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

weiraowang 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 b29965bdce [Fix] In updateWorkerNodes method, the 
workerNodeInfoWriteLock should be used. #15898 (#15903)
b29965bdce is described below

commit b29965bdce2b5b83c1ffe237265e6f53f01e11cf
Author: DaqianLiao <360989...@qq.com>
AuthorDate: Fri Apr 26 11:24:05 2024 +0800

    [Fix] In updateWorkerNodes method, the workerNodeInfoWriteLock should be 
used. #15898 (#15903)
    
    Co-authored-by: answerliao <answerl...@tencent.com>
---
 .../dolphinscheduler/server/master/registry/ServerNodeManager.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
index 258acd8f6e..f066f0403d 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManager.java
@@ -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();
         }
     }