This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new 4ac025b387b [fix][meta] Adding the missed bookie id in the 
registration manager. (#20641)
4ac025b387b is described below

commit 4ac025b387b935ba28a59fbe8879f774436f4ee3
Author: Qiang Zhao <[email protected]>
AuthorDate: Thu Jun 29 13:14:55 2023 +0800

    [fix][meta] Adding the missed bookie id in the registration manager. 
(#20641)
---
 .../apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java
index ca53339591f..f964a1851e0 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java
@@ -135,7 +135,7 @@ public class PulsarRegistrationManager implements 
RegistrationManager {
             if (readOnly) {
                 ResourceLock<BookieServiceInfo> rwRegistration = 
bookieRegistration.remove(bookieId);
                 if (rwRegistration != null) {
-                    log.info("Bookie {} was already registered as writable, 
unregistering");
+                    log.info("Bookie {} was already registered as writable, 
unregistering", bookieId);
                     rwRegistration.release().get();
                 }
 
@@ -144,7 +144,7 @@ public class PulsarRegistrationManager implements 
RegistrationManager {
             } else {
                 ResourceLock<BookieServiceInfo> roRegistration = 
bookieRegistrationReadOnly.remove(bookieId);
                 if (roRegistration != null) {
-                    log.info("Bookie {} was already registered as read-only, 
unregistering");
+                    log.info("Bookie {} was already registered as read-only, 
unregistering", bookieId);
                     roRegistration.release().get();
                 }
 

Reply via email to