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()) {