From b29965bdce2b5b83c1ffe237265e6f53f01e11cf Mon Sep 17 00:00:00 2001
From: DaqianLiao <360989637@qq.com>
Date: Fri, 26 Apr 2024 11:24:05 +0800
Subject: [PATCH] [Fix] In updateWorkerNodes method, the
 workerNodeInfoWriteLock should be used. #15898 (#15903)

Co-authored-by: answerliao <answerliao@tencent.com>
---
 .../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();
         }
     }