This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit e375892af639194b48450389369129fc68be91b6 Author: mingyifei <[email protected]> AuthorDate: Thu Jan 13 01:06:51 2022 +0800 [pulsar-broker] The log prints NamespaceService#isServiceUnitActive exception stack information (#13553) (cherry picked from commit 58c281811b01dfc2bcf1906865964badbee4a952) --- .../java/org/apache/pulsar/broker/namespace/NamespaceService.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java index 4fff4b0..1a42c19 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java @@ -991,9 +991,13 @@ public class NamespaceService implements AutoCloseable { public boolean isServiceUnitActive(TopicName topicName) { try { - return ownershipCache.getOwnedBundle(getBundle(topicName)).isActive(); + OwnedBundle ownedBundle = ownershipCache.getOwnedBundle(getBundle(topicName)); + if (ownedBundle == null) { + return false; + } + return ownedBundle.isActive(); } catch (Exception e) { - LOG.warn("Unable to find OwnedBundle for topic - [{}]", topicName); + LOG.warn("Unable to find OwnedBundle for topic - [{}]", topicName, e); return false; } }
