From 34dbe801c322e80100d8ede8e2ba2db5c9223c81 Mon Sep 17 00:00:00 2001 From: Rishab Nahata Date: Thu, 27 Oct 2022 15:51:10 +0530 Subject: [PATCH] Fix spotless check Signed-off-by: Rishab Nahata --- .../cluster/routing/WeightedRoutingService.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/opensearch/cluster/routing/WeightedRoutingService.java b/server/src/main/java/org/opensearch/cluster/routing/WeightedRoutingService.java index 67e7557316be6..190f45084bd5d 100644 --- a/server/src/main/java/org/opensearch/cluster/routing/WeightedRoutingService.java +++ b/server/src/main/java/org/opensearch/cluster/routing/WeightedRoutingService.java @@ -19,7 +19,6 @@ import org.opensearch.cluster.ClusterState; import org.opensearch.cluster.ClusterStateUpdateTask; import org.opensearch.cluster.ack.ClusterStateUpdateResponse; -import org.opensearch.cluster.decommission.DecommissionAttribute; import org.opensearch.cluster.decommission.DecommissionAttributeMetadata; import org.opensearch.cluster.decommission.DecommissionStatus; import org.opensearch.cluster.metadata.Metadata; @@ -165,8 +164,14 @@ public void ensureNoWeightUpdateForDecommissionedAttribute(ClusterState state, C DecommissionAttributeMetadata decommissionAttributeMetadata = state.metadata().decommissionAttributeMetadata(); if (decommissionAttributeMetadata != null && decommissionAttributeMetadata.status().equals(DecommissionStatus.FAILED) == false - && Objects.equals(request.getWeightedRouting().attributeName(), decommissionAttributeMetadata.decommissionAttribute().attributeName()) - && Objects.equals(request.getWeightedRouting().weights().get(decommissionAttributeMetadata.decommissionAttribute().attributeValue()), 0.0) == false) { + && Objects.equals( + request.getWeightedRouting().attributeName(), + decommissionAttributeMetadata.decommissionAttribute().attributeName() + ) + && Objects.equals( + request.getWeightedRouting().weights().get(decommissionAttributeMetadata.decommissionAttribute().attributeValue()), + 0.0 + ) == false) { throw new IllegalStateException( "a decommission action is ongoing with status [" + decommissionAttributeMetadata.status().status()