From 0eb8d733d42bb644dad65f74b8d8adba5a0fef8c Mon Sep 17 00:00:00 2001 From: Karan Kumar Date: Tue, 3 Dec 2024 22:36:53 +0530 Subject: [PATCH] Adding leader and not being leader logging on the overlord. (#17519) --- .../java/org/apache/druid/indexing/overlord/DruidOverlord.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/DruidOverlord.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/DruidOverlord.java index f8d011c70d80..547b63a70f07 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/DruidOverlord.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/DruidOverlord.java @@ -106,7 +106,7 @@ public void becomeLeader() giant.lock(); // I AM THE MASTER OF THE UNIVERSE. - log.info("By the power of Grayskull, I have the power!"); + log.info("By the power of Grayskull, I have the power. I am the leader"); try { final TaskRunner taskRunner = runnerFactory.build(); @@ -193,6 +193,7 @@ public void stopBeingLeader() giant.lock(); try { initialized = false; + log.info("I am no longer the leader..."); final Lifecycle leaderLifecycle = leaderLifecycleRef.getAndSet(null); if (leaderLifecycle != null) {