diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java
index a5d503b..a5c8073 100644
--- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java
+++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java
@@ -248,6 +248,8 @@
 
     Map<String, Map<IOption, Object>> getActiveNcConfiguration();
 
+    boolean isPendingRemoval(String nodeId);
+
     /**
      * Sets the cluster partition in which metadata datasets stored
      *
diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
index 444d91b..7c9fd5b 100644
--- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
+++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
@@ -479,6 +479,11 @@
     }
 
     @Override
+    public synchronized boolean isPendingRemoval(String nodeId) {
+        return pendingRemoval.contains(nodeId);
+    }
+
+    @Override
     public synchronized void setMetadataPartitionId(ClusterPartition partition) {
         metadataPartition = partition;
     }