You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2020/10/27 16:32:49 UTC
[pulsar] branch master updated: [pulsar-broker-log] Add info log
when broker doesn't find enough bookie in primary isolation group (#8315)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 47325d2 [pulsar-broker-log] Add info log when broker doesn't find enough bookie in primary isolation group (#8315)
47325d2 is described below
commit 47325d2c0f99a30431dbe52971487e2c4ca54966
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Tue Oct 27 09:32:31 2020 -0700
[pulsar-broker-log] Add info log when broker doesn't find enough bookie in primary isolation group (#8315)
### Motivation
Add info log when broker doesn't find enough available bookies in primary isolation group to help in troubleshooting.
---
.../pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java
index 191450f..f508e64 100644
--- a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java
+++ b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java
@@ -192,6 +192,9 @@ public class ZkIsolatedBookieEnsemblePlacementPolicy extends RackawareEnsemblePl
}
// if primary-isolated-bookies are not enough then add consider secondary isolated bookie group as well.
if (totalAvailableBookiesInPrimaryGroup < ensembleSize) {
+ LOG.info(
+ "Not found enough available-bookies from primary isolation group {} , checking secondary group",
+ primaryIsolationGroups, secondaryIsolationGroups);
for (String group : secondaryIsolationGroups) {
Map<String, BookieInfo> bookieGroup = allGroupsBookieMapping.get(group);
if (bookieGroup != null && !bookieGroup.isEmpty()) {