diff --git a/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java b/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java index 8024edf3daa..34a0ade4574 100644 --- a/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java +++ b/server/src/main/java/io/druid/server/coordination/ZkCoordinator.java @@ -386,7 +386,7 @@ public class ZkCoordinator extends BaseZkCoordinator // get any exception that may have been thrown in background annoucing try { - // check in case we did not call startAnnouncing + // check in case intervalMillis is <= 0 if (startedAnnouncing != null) { startedAnnouncing.cancel(false); }