You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2023/07/04 08:29:39 UTC
[pulsar] branch branch-2.10 updated: [fix][meta] Adding the missed bookie id in the registration manager. (#20641)
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 <ma...@apache.org>
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();
}