emitSDStatusActiveUpdateIntentAndWriteEvents updated

linkedin · Oct 11, 2024 · b319ad5 · b319ad5
1 parent 7a8fcc8
commit b319ad5
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java b/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java
@@ -724,6 +724,10 @@ public void setEventEmitter(ServiceDiscoveryEventEmitter emitter) {
 
   @Override
   public void emitSDStatusActiveUpdateIntentAndWriteEvents(String cluster, boolean isMarkUp, boolean succeeded, long startAt) {
+    if (_server instanceof ZooKeeperServer)
+    {
+      return;
+    }
     if (_eventEmitter == null) {
       _log.info("Service discovery event emitter in ZookeeperAnnouncer is null. Skipping emitting events.");
       return;