You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/01/25 23:30:21 UTC
[incubator-pulsar] branch master updated: Fix: deadlock while
closing non-persistent topic (#1113)
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 <rd...@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
mmerli@apache.org.