Michael Blow has submitted this change and it was merged. ( https://asterix-gerrit.ics.uci.edu/3335 )
Change subject: [NO ISSUE][*DB][CLUS] Add failed nodes API to ClusterStateManager ...................................................................... [NO ISSUE][*DB][CLUS] Add failed nodes API to ClusterStateManager Change-Id: I1b56b29c38f0bbfe54b30ee5781770e90404c528 Reviewed-on: https://asterix-gerrit.ics.uci.edu/3335 Tested-by: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Reviewed-by: Till Westmann <[email protected]> --- M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java M asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java 2 files changed, 10 insertions(+), 0 deletions(-) Approvals: Jenkins: Verified; Verified Anon. E. Moose (1000171): Till Westmann: Looks good to me, approved Objections: Jenkins: Violations found 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 5e99eec..d0d039d 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 @@ -139,6 +139,11 @@ Set<String> getParticipantNodes(); /** + * @return the set of currently failed nodes + */ + Set<String> getFailedNodes(); + + /** * Returns the IO devices configured for a Node Controller * * @param nodeId 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 8d3187b..720b089 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 @@ -251,6 +251,11 @@ } @Override + public synchronized Set<String> getFailedNodes() { + return new HashSet<>(failedNodes); + } + + @Override public synchronized Set<String> getParticipantNodes(boolean excludePendingRemoval) { final Set<String> participantNodesCopy = getParticipantNodes(); if (excludePendingRemoval) { -- To view, visit https://asterix-gerrit.ics.uci.edu/3335 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-Project: asterixdb Gerrit-Branch: stabilization-f69489 Gerrit-MessageType: merged Gerrit-Change-Id: I1b56b29c38f0bbfe54b30ee5781770e90404c528 Gerrit-Change-Number: 3335 Gerrit-PatchSet: 2 Gerrit-Owner: Michael Blow <[email protected]> Gerrit-Reviewer: Anon. E. Moose (1000171) Gerrit-Reviewer: Ian Maxon <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Michael Blow <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: Till Westmann <[email protected]>
