[pulsar-broker] Handle NPE in unblock stuck subscrption task when dis…

…patcher is not created (apache#10430)
lujp · May 4, 2021 · 9982492 · 9982492
1 parent 504c4f3
commit 9982492
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java b/...ker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -1098,7 +1098,7 @@ public boolean checkIsCanDeleteConsumerPendingAck(PositionImpl position) {
     }
 
     public boolean checkAndUnblockIfStuck() {
-        return dispatcher.checkAndUnblockIfStuck();
+        return dispatcher != null ? dispatcher.checkAndUnblockIfStuck() : false;
     }
 
     private static final Logger log = LoggerFactory.getLogger(PersistentSubscription.class);