HBASE-27810. Check if event processor is already shut down (apache#5212)

(cherry picked from commit 2bd5666) Change-Id: Ide19d37ce85d614f39d80bbc186ca8811a4704a9
vinayakphegde · May 8, 2023 · da2c7ff · da2c7ff
1 parent 23333c4
commit da2c7ff
Showing 1 changed file with 3 additions and 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
@@ -599,7 +599,9 @@ private void processEvent(WatchedEvent event) {
   public void process(WatchedEvent event) {
     LOG.debug(prefix("Received ZooKeeper Event, " + "type=" + event.getType() + ", " + "state="
       + event.getState() + ", " + "path=" + event.getPath()));
-    zkEventProcessor.execute(() -> processEvent(event));
+    if (!zkEventProcessor.isShutdown()) {
+      zkEventProcessor.execute(() -> processEvent(event));
+    }
   }
 
   // Connection management