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

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


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

commit c5f21283bb2252eaacccc70ffb5c89b8e192ebbf
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 b34b8e682f0..383510843a8 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
@@ -132,7 +132,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();
                 }
 
@@ -141,7 +141,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