You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/10/02 00:57:38 UTC
[pulsar] 01/02: [fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9de48f570a5e3a8a856c3f47d1cc39f5811dd08f
Author: Penghui Li <pe...@apache.org>
AuthorDate: Sun Oct 2 08:46:09 2022 +0800
[fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)
(cherry picked from commit e26060a1e15a3488fc93cdff6bb0e95e7ec52fed)
---
.../src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
index 2cee1c7a627..c59ea0a940b 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
@@ -75,7 +75,7 @@ public class ZKMetadataStore extends AbstractMetadataStore implements MetadataSt
.sessionTimeoutMs(metadataStoreConfig.getSessionTimeoutMillis())
.watchers(Collections.singleton(event -> {
if (sessionWatcher != null) {
- sessionWatcher.ifPresent(sw -> sw.process(event));
+ sessionWatcher.ifPresent(sw -> executor.execute(() -> sw.process(event)));
}
}))
.build();