From a003aee25aad412f2b85932180e144158dcb604e Mon Sep 17 00:00:00 2001 From: brycezhongqing Date: Tue, 15 Oct 2024 10:08:57 -0700 Subject: [PATCH] emitSDStatusActiveUpdateIntentAndWriteEvents updated --- .../com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java | 5 +---- 1 file changed, 1 insertion(+), 4 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 index f967efac9..389eb697e 100644 --- a/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java +++ b/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java @@ -481,10 +481,7 @@ public void onError(Throwable e) @Override public void onSuccess(None result) { - if (_server instanceof ZooKeeperServer) - { - emitSDStatusActiveUpdateIntentAndWriteEvents(_cluster, false, true, _markDownStartAtRef.get()); - } + emitSDStatusActiveUpdateIntentAndWriteEvents(_cluster, false, true, _markDownStartAtRef.get()); _log.info("markDown for uri = {} succeeded.", _uri); // Note that the pending callbacks we see at this point are // from the requests that are filed before us because zookeeper