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:37 UTC
[pulsar] branch branch-2.9 updated (b07d31bf12f -> 1f8cef3d8e7)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from b07d31bf12f [branch-2.9] Fix cherry-pick issue (#17894)
new 9de48f570a5 [fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)
new 1f8cef3d8e7 Make executor of AbstractMetadataStore protected
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java | 2 +-
.../src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
[pulsar] 01/02: [fix][broker] Fix the broker shutdown issue after Zookeeper node crashed (#17909)
Posted by pe...@apache.org.
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();
[pulsar] 02/02: Make executor of AbstractMetadataStore protected
Posted by pe...@apache.org.
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 1f8cef3d8e741143971ad89f67fe4507a9191769
Author: penghui <pe...@apache.org>
AuthorDate: Sun Oct 2 08:57:23 2022 +0800
Make executor of AbstractMetadataStore protected
---
.../java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
index 4346d8ad408..40c209f4d3e 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -62,7 +62,7 @@ public abstract class AbstractMetadataStore implements MetadataStoreExtended, Co
private final CopyOnWriteArrayList<Consumer<Notification>> listeners = new CopyOnWriteArrayList<>();
private final CopyOnWriteArrayList<Consumer<SessionEvent>> sessionListeners = new CopyOnWriteArrayList<>();
- private final ExecutorService executor;
+ protected final ExecutorService executor;
private final AsyncLoadingCache<String, List<String>> childrenCache;
private final AsyncLoadingCache<String, Boolean> existsCache;
private final CopyOnWriteArrayList<MetadataCacheImpl<?>> metadataCaches = new CopyOnWriteArrayList<>();