Skip to content

Commit

Permalink
Remove unused code
Browse files Browse the repository at this point in the history
Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
  • Loading branch information
pranikum committed Sep 26, 2022
1 parent bf622c4 commit d933377
Showing 1 changed file with 1 addition and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -383,20 +383,15 @@ public void run() {
getActiveRequestCountOnDecommissionNodes(decommissionedNodes);
removeDecommissionedNodes(decommissionedNodes, reason, timeout, nodesRemovedListener);
}

@Override
public String toString() {
return "";
}
}, timeoutForNodeDecommission, org.opensearch.threadpool.ThreadPool.Names.SAME);
}

private void getActiveRequestCountOnDecommissionNodes(Set<DiscoveryNode> decommissionedNodes) {
if (decommissionedNodes == null || decommissionedNodes.isEmpty()) {
return;
}
String[] nodes = decommissionedNodes.stream().map(DiscoveryNode::getId).toArray(String[]::new);

String[] nodes = decommissionedNodes.stream().map(DiscoveryNode::getId).toArray(String[]::new);
if (nodes.length == 0) {
return;
}
Expand Down

0 comments on commit d933377

Please sign in to comment.