commit 58c281811b01dfc2bcf1906865964badbee4a952
author mingyifei <965162704@qq.com> Thu Jan 13 01:06:51 2022 +0800
committer GitHub <noreply@github.com> Thu Jan 13 01:06:51 2022 +0800
tree d55fffa79f3fb94b19ffe6acd560042fe3343b1e
parent 5835191295371b3a5f49ed1019a8ad197554424e

[pulsar-broker] The log prints NamespaceService#isServiceUnitActive exception stack information (#13553)

pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java

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 e83eaad..5e2ee96 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
@@ -980,9 +980,13 @@
 
     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;
         }
     }