[fix][broker] AbstractBatchedMetadataStore - use AlreadyClosedExcepti…

…on instead of IllegalStateException (apache#19284) (cherry picked from commit d3e112e)
datastax · Jan 19, 2023 · 6b9967f · 6b9967f
1 parent addb664
commit 6b9967f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java b/.../src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
@@ -30,6 +30,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.apache.pulsar.metadata.api.GetResult;
 import org.apache.pulsar.metadata.api.MetadataStoreConfig;
+import org.apache.pulsar.metadata.api.MetadataStoreException;
 import org.apache.pulsar.metadata.api.Stat;
 import org.apache.pulsar.metadata.api.extended.CreateOption;
 import org.apache.pulsar.metadata.impl.AbstractMetadataStore;
@@ -74,7 +75,8 @@ protected AbstractBatchedMetadataStore(MetadataStoreConfig conf) {
     public void close() throws Exception {
         if (enabled) {
             // Fail all the pending items
-            Exception ex = new IllegalStateException("Metadata store is getting closed");
+            MetadataStoreException ex =
+                    new MetadataStoreException.AlreadyClosedException("Metadata store is getting closed");
             readOps.drain(op -> op.getFuture().completeExceptionally(ex));
             writeOps.drain(op -> op.getFuture().completeExceptionally(ex));