From 9a3a6f5a3d5ec613b49ae1a5a947d58c351f1fc7 Mon Sep 17 00:00:00 2001 From: "DK.Pino" Date: Thu, 12 Dec 2019 14:20:27 +0800 Subject: [PATCH] fix comment error (#1446) --- .../server/master/runner/MasterSchedulerThread.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java index 27f417d501..69c2304cd7 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java @@ -101,7 +101,7 @@ public class MasterSchedulerThread implements Runnable { if(OSUtils.checkResource(masterConfig.getMasterMaxCpuloadAvg(), masterConfig.getMasterReservedMemory())){ if (zkMasterClient.getZkClient().getState() == CuratorFrameworkState.STARTED) { - // create distributed lock with the root node path of the lock space as /dolphinscheduler/lock/failover/master + // create distributed lock with the root node path of the lock space as /dolphinscheduler/lock/masters String znodeLock = zkMasterClient.getMasterLockPath(); mutex = new InterProcessMutex(zkMasterClient.getZkClient(), znodeLock);