From 2d617b56c85c9db90a6fec0719f48e851d5c6e8f Mon Sep 17 00:00:00 2001 From: qiaozhanwei Date: Thu, 23 May 2019 15:56:54 +0800 Subject: [PATCH] master startup lock dev update --- .../main/java/cn/escheduler/server/zk/ZKMasterClient.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java b/escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java index 8d2410098d..e5ef726f9c 100644 --- a/escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java +++ b/escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java @@ -115,9 +115,9 @@ public class ZKMasterClient extends AbstractZKClient { InterProcessMutex mutex = null; try { // create distributed lock with the root node path of the lock space as /escheduler/lock/failover/master - String znodeLock = zkMasterClient.getMasterStartUpLockPath(); + String znodeLock = getMasterStartUpLockPath(); - mutex = new InterProcessMutex(zkMasterClient.getZkClient(), znodeLock); + mutex = new InterProcessMutex(zkClient, znodeLock); mutex.acquire(); // init system znode @@ -138,7 +138,7 @@ public class ZKMasterClient extends AbstractZKClient { } }catch (Exception e){ - logger.error("master scheduler thread exception : " + e.getMessage(),e); + logger.error("master start up exception : " + e.getMessage(),e); }finally { if (mutex != null){ try {