This is an automated email from the ASF dual-hosted git repository.
chenhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push:
new a12943df27 Change the new ensemble log to info level (#4566)
a12943df27 is described below
commit a12943df277e698a1621d33c245913365d031257
Author: Yong Zhang <[email protected]>
AuthorDate: Wed Mar 19 10:26:02 2025 +0800
Change the new ensemble log to info level (#4566)
---
### Motivation
Change the new ensemble log to the info level. Sometimes, the ensemble
may not satisfied with the placement policy. The log should be info
level but not a warn level. Because it will fix by the auto recovery
later, so this just a information from the ensemble choose.
---
.../src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java
index 978842b114..f7af154928 100644
---
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java
+++
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java
@@ -273,7 +273,7 @@ class BookieWatcherImpl implements BookieWatcher {
if (isEnsembleAdheringToPlacementPolicy ==
PlacementPolicyAdherence.FAIL) {
ensembleNotAdheringToPlacementPolicy.inc();
if (ensembleSize > 1) {
- log.warn("New ensemble: {} is not adhering to Placement
Policy. quarantinedBookies: {}",
+ log.info("New ensemble: {} is not adhering to Placement
Policy. quarantinedBookies: {}",
socketAddresses, quarantinedBookiesSet);
}
}
@@ -289,7 +289,7 @@ class BookieWatcherImpl implements BookieWatcher {
isEnsembleAdheringToPlacementPolicy =
newEnsembleResponse.getAdheringToPolicy();
if (isEnsembleAdheringToPlacementPolicy ==
PlacementPolicyAdherence.FAIL) {
ensembleNotAdheringToPlacementPolicy.inc();
- log.warn("New ensemble: {} is not adhering to Placement
Policy", socketAddresses);
+ log.info("New ensemble: {} is not adhering to Placement
Policy", socketAddresses);
}
newEnsembleTimer.registerFailedEvent(MathUtils.nowInNano() -
startTime, TimeUnit.NANOSECONDS);
}