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 f8d011c70d8..547b63a70f0 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 class DruidOverlord 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 class DruidOverlord giant.lock(); try { initialized = false; + log.info("I am no longer the leader..."); final Lifecycle leaderLifecycle = leaderLifecycleRef.getAndSet(null); if (leaderLifecycle != null) {