[pulsar] branch branch-2.10 updated: [fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)

[pe...@apache.org]

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

penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 9c985d35653 [fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)
9c985d35653 is described below

commit 9c985d35653afdf3d424bff59728f93c6321aae5
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 4b7649b221e..4676843b972 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
@@ -98,7 +98,7 @@ public class ZKMetadataStore extends AbstractBatchedMetadataStore
                     .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();