From 4c55c61633c7db50cae5d3c42ac7efebed21acca Mon Sep 17 00:00:00 2001 From: wusheng Date: Fri, 11 Dec 2015 21:40:29 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=8A=A0=E4=B8=8A=E9=83=A8=E5=88=86=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java index f3858bbd2..f3f66418e 100644 --- a/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java +++ b/skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/UserInfoCoordinator.java @@ -46,6 +46,7 @@ public class UserInfoCoordinator extends Thread { } } + logger.info("becoming cluster coordinator."); isCoordinator = true; watcherRegisterServerPath(); redistributing = true; @@ -113,7 +114,7 @@ public class UserInfoCoordinator extends Thread { } } catch (Exception e) { - logger.error("Failed to coordinate, retry. ", e); + logger.error("Failed to coordinate, release lock. ", e); releaseCoordinator(); isCoordinator = false; }