(asterixdb) 03/19: [NO ISSUE][*DB][MISC] += ClusterStateManager.isPendingRemoval

[preetham02]

This is an automated email from the ASF dual-hosted git repository.

preetham02 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git

commit 389d8c08d24b0a8a1b7c89fd781709d334bbb126
Author: Michael Blow <michael.b...@couchbase.com>
AuthorDate: Sat Jun 28 16:47:05 2025 -0400

    [NO ISSUE][*DB][MISC] += ClusterStateManager.isPendingRemoval
    
    Ext-ref: MB-67132
    Change-Id: Ib7741273d74547f5a6951f3d3906d71cc1ab0119
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20007
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Michael Blow <mb...@apache.org>
    Reviewed-by: Hussain Towaileb <hussai...@gmail.com>
---
 .../java/org/apache/asterix/common/cluster/IClusterStateManager.java | 2 ++
 .../java/org/apache/asterix/runtime/utils/ClusterStateManager.java   | 5 +++++
 2 files changed, 7 insertions(+)

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 a5d503b8c3..a5c8073d61 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 @@ public interface IClusterStateManager {
 
     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 444d91bd32..7c9fd5bdd0 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
@@ -478,6 +478,11 @@ public class ClusterStateManager implements 
IClusterStateManager {
         return new HashSet<>(pendingRemoval);
     }
 
+    @Override
+    public synchronized boolean isPendingRemoval(String nodeId) {
+        return pendingRemoval.contains(nodeId);
+    }
+
     @Override
     public synchronized void setMetadataPartitionId(ClusterPartition 
partition) {
         metadataPartition = partition;