[incubator-pulsar] branch master updated: Fix: deadlock while closing non-persistent topic (#1113)

[mmerli]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 1d10e69  Fix: deadlock while closing non-persistent topic (#1113)
1d10e69 is described below

commit 1d10e696218c4f0ce2bc810a687fe14baf5295db
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Thu Jan 25 15:30:19 2018 -0800

    Fix: deadlock while closing non-persistent topic (#1113)
---
 .../apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
index 308d8c8..3b162ab 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -456,7 +456,7 @@ public class NonPersistentTopic implements Topic {
 
         FutureUtil.waitForAll(futures).thenRun(() -> {
             log.info("[{}] Topic closed", topic);
-            brokerService.removeTopicFromCache(topic);
+            brokerService.pulsar().getExecutor().submit(() -> 
brokerService.removeTopicFromCache(topic));
             closeFuture.complete(null);
         }).exceptionally(exception -> {
             log.error("[{}] Error closing topic", topic, exception);

-- 
To stop receiving notification emails like this one, please contact
mme...@apache.org.