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; }