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 <[email protected]>
