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/03 11:31:56 UTC
[pulsar] branch branch-3.0 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-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new f8373dc4494 [fix][meta] Adding the missed bookie id in the registration manager. (#20641)
f8373dc4494 is described below
commit f8373dc4494072c8bbb9b2aff49bb1754bdf3ab1
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 32ec89e717e..25c3f10aa18 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();
}