HBASE-27810. Check if the executor has already been shut down before …

…submitting new job (#5207) Signed-off-by: Wellington Chevreuil <[email protected]> Signed-off-by: Duo Zhang <[email protected]> (cherry picked from commit a6e89bf)
apache · Apr 28, 2023 · de3d0ae · de3d0ae
1 parent adfcea8
commit de3d0ae
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
@@ -604,7 +604,9 @@ public void process(WatchedEvent event) {
     LOG.debug(prefix("Received ZooKeeper Event, " + "type=" + event.getType() + ", " + "state="
       + event.getState() + ", " + "path=" + event.getPath()));
     final String spanName = ZKWatcher.class.getSimpleName() + "-" + identifier;
-    zkEventProcessor.execute(TraceUtil.tracedRunnable(() -> processEvent(event), spanName));
+    if (!zkEventProcessor.isShutdown()) {
+      zkEventProcessor.execute(TraceUtil.tracedRunnable(() -> processEvent(event), spanName));
+    }
   }
 
   // Connection management