You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by lh...@apache.org on 2025/04/17 12:03:41 UTC
(bookkeeper) 04/08: when failed to choose a bookie, print out the list of ensemble. (#4482)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.15
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 305505b15a958098188f1ad5f231d66e32987c2c
Author: Dezhiliu <33...@users.noreply.github.com>
AuthorDate: Wed Aug 21 06:57:15 2024 +0800
when failed to choose a bookie, print out the list of ensemble. (#4482)
### Motivation
In file RackawareEnsemblePlacementPolicyImpl.java
In the log.warn below, we should print out the list of ensemble, instead of the object. The “ensemble” in line-619 should be changed into “ensemble.toList()”.
https://github.com/apache/bookkeeper/blob/999cd0f2ab14404be4d6c24e388456dbe56bb1a8/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java#L600C3-L619C47
### Changes
The “ensemble” in line-619 changed into “ensemble.toList()”.
(cherry picked from commit 7c41204506122ed6904289f4814d4130274874aa)
---
.../bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java
index b01890dcfa..161fadd3c5 100644
--- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java
+++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java
@@ -535,7 +535,7 @@ public class RackawareEnsemblePlacementPolicyImpl extends TopologyAwareEnsembleP
LOG.warn("Failed to choose a bookie from network location {}, "
+ "the bookies in the network location are {}, excluded bookies {}, "
+ "current ensemble {}, fallback to choose bookie randomly from the cluster.",
- networkLoc, topology.getLeaves(networkLoc), excludeBookies, ensemble);
+ networkLoc, topology.getLeaves(networkLoc), excludeBookies, ensemble.toList());
// randomly choose one from whole cluster, ignore the provided predicate.
return selectRandom(1, excludeBookies, predicate, ensemble).get(0);
}
@@ -561,7 +561,7 @@ public class RackawareEnsemblePlacementPolicyImpl extends TopologyAwareEnsembleP
LOG.warn("Failed to choose a bookie node from network location {}, "
+ "the bookies in the network location are {}, excluded bookies {}, "
+ "current ensemble {}, fallback to choose bookie randomly from the cluster.",
- networkLoc, topology.getLeaves(networkLoc), excludeBookies, ensemble);
+ networkLoc, topology.getLeaves(networkLoc), excludeBookies, ensemble.toList());
return selectFromNetworkLocation(excludeRacks, excludeBookies, predicate, ensemble, fallbackToRandom);
}
}