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();
}