You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2023/05/01 15:49:15 UTC
[hbase] branch branch-2.4 updated: HBASE-27810. Check if event processor is already shut down (#5212)
This is an automated email from the ASF dual-hosted git repository.
rajeshbabu pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 2bd56661fce HBASE-27810. Check if event processor is already shut down (#5212)
2bd56661fce is described below
commit 2bd56661fce60e8dac2c9cf8d1e4d5867fab5ec7
Author: Andor Molnár <an...@cloudera.com>
AuthorDate: Mon May 1 17:49:09 2023 +0200
HBASE-27810. Check if event processor is already shut down (#5212)
---
.../src/main/java/org/apache/hadoop/hbase/zookeeper/ZKWatcher.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKWatcher.java b/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKWatcher.java
index f6bff056271..d6c948931bb 100644
--- a/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKWatcher.java
+++ b/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKWatcher.java
@@ -599,7 +599,9 @@ public class ZKWatcher implements Watcher, Abortable, Closeable {
public void process(WatchedEvent event) {
LOG.debug(prefix("Received ZooKeeper Event, " + "type=" + event.getType() + ", " + "state="
+ event.getState() + ", " + "path=" + event.getPath()));
- zkEventProcessor.submit(() -> processEvent(event));
+ if (!zkEventProcessor.isShutdown()) {
+ zkEventProcessor.submit(() -> processEvent(event));
+ }
}
// Connection management