Fix spotless check

Signed-off-by: Rishab Nahata <rnnahata@amazon.com>
opensearch-project · Oct 27, 2022 · 34dbe80 · 34dbe80
1 parent 976f7da
commit 34dbe80
Showing 1 changed file with 8 additions and 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
@@ -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()