abdullah alamoudi has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/1909
Change subject: [ASTERIXDB-2008][CLUS] Only add pending removal if node known ...................................................................... [ASTERIXDB-2008][CLUS] Only add pending removal if node known - user model changes: no - storage format changes: no - interface changes: no details: - Only nodes which are known to cluster manager are added to the list of nodes pending removal. Other nodes are ignored Change-Id: Id3f60c1ecc74f400a6eeb0aa1f9bb4ba668ce9c6 --- M asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java 1 file changed, 3 insertions(+), 2 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/09/1909/1 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 4717a7b..3b23d67 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 @@ -389,10 +389,11 @@ if (LOGGER.isLoggable(Level.INFO)) { LOGGER.info("Registering intention to remove node id " + nodeId); } - if (!activeNcConfiguration.containsKey(nodeId)) { + if (activeNcConfiguration.containsKey(nodeId)) { + pendingRemoval.add(nodeId); + } else { LOGGER.warning("Cannot register unknown node " + nodeId + " for pending removal"); } - pendingRemoval.add(nodeId); } public synchronized boolean cancelRemovePending(String nodeId) { -- To view, visit https://asterix-gerrit.ics.uci.edu/1909 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: Id3f60c1ecc74f400a6eeb0aa1f9bb4ba668ce9c6 Gerrit-PatchSet: 1 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <bamou...@gmail.com>