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.