Skip to content

Commit

Permalink
[fix][meta] Adding the missed bookie id in the registration manager. (a…
Browse files Browse the repository at this point in the history
…pache#20641)

(cherry picked from commit c5f2128)
  • Loading branch information
mattisonchao authored and nicoloboschi committed Jul 17, 2023
1 parent fa43cf7 commit f99a67e
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ public void registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInf
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();
}

Expand All @@ -141,7 +141,7 @@ public void registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInf
} 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();
}

Expand Down

0 comments on commit f99a67e

Please sign in to comment.