fix some comment

congbobo184 · May 6, 2024 · 315b4af · 315b4af
1 parent b4a7b44
commit 315b4af
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataClientDriver.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataClientDriver.java
@@ -113,7 +113,7 @@ public void setSessionStateListener(SessionStateListener sessionStateListener) {
         });
     }
 
-    public CompletableFuture<Boolean> isMetadataServiceAvailable() {
+    public synchronized CompletableFuture<Boolean> isMetadataServiceAvailable() {
         return CompletableFuture.completedFuture(metadataServiceAvailable);
     }
 }
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataDriverBase.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataDriverBase.java
@@ -218,7 +218,9 @@ protected void initialize(AbstractConfiguration<?> conf,
                     .operationRetryPolicy(zkRetryPolicy)
                     .requestRateLimit(conf.getZkRequestRateLimit())
                     .watchers(Collections.singleton(watchedEvent -> {
-                        log.info("Got ZK session watch event: {}", watchedEvent);
+                        if (log.isDebugEnabled()) {
+                            log.debug("Got ZK session watch event: {}", watchedEvent);
+                        }
                         handleState(watchedEvent.getState());
                     }))
                     .statsLogger(statsLogger)
@@ -265,7 +267,6 @@ private synchronized void handleState(Watcher.Event.KeeperState zkClientState) {
 
             default:
                 this.metadataServiceAvailable = true;
-                break;
         }
     }