Add assert for local node

Signed-off-by: Anshu Agarwal <anshukag@amazon.com>
opensearch-project · Feb 8, 2023 · d4c61c4 · d4c61c4
1 parent dbd57e1
commit d4c61c4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...rc/main/java/org/opensearch/action/admin/cluster/health/TransportClusterHealthAction.java b/...rc/main/java/org/opensearch/action/admin/cluster/health/TransportClusterHealthAction.java
@@ -281,6 +281,7 @@ private void executeHealth(
             ClusterHealthResponse clusterHealthResponse = getResponse(request, currentState, waitCount, TimeoutState.OK);
             if (request.ensureNodeWeighedIn() && clusterHealthResponse.hasDiscoveredClusterManager()) {
                 DiscoveryNode localNode = clusterService.state().getNodes().getLocalNode();
+                assert localNode != null;
                 boolean weighedAway = WeightedRoutingUtils.isWeighedAway(localNode.getId(), clusterService.state());
                 if (weighedAway) {
                     listener.onFailure(new NodeWeighedAwayException("local node is weighed away"));