Fix spotless check

Signed-off-by: Rishab Nahata <[email protected]>
imRishN · Jul 23, 2024 · 5c40c99 · 5c40c99
1 parent 109616a
commit 5c40c99
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 4 deletions.
diff --git a/...r/src/main/java/org/opensearch/cluster/routing/allocation/AllocateUnassignedDecision.java b/...r/src/main/java/org/opensearch/cluster/routing/allocation/AllocateUnassignedDecision.java
@@ -105,7 +105,7 @@ public class AllocateUnassignedDecision extends AbstractAllocationDecision {
     private final long remainingDelayInMillis;
     private final long configuredDelayInMillis;
 
-    public AllocateUnassignedDecision(
+    private AllocateUnassignedDecision(
         AllocationStatus allocationStatus,
         DiscoveryNode assignedNode,
         String allocationId,

diff --git a/server/src/main/java/org/opensearch/cluster/routing/allocation/AllocationService.java b/server/src/main/java/org/opensearch/cluster/routing/allocation/AllocationService.java
@@ -569,7 +569,10 @@ private void reroute(RoutingAllocation allocation) {
 
         long startTime = System.nanoTime();
         allocateExistingUnassignedShards(allocation);  // try to allocate existing shard copies first
-        logger.debug("Completing allocateExistingUnassignedShards, elapsed time: [{}]", TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startTime));
+        logger.debug(
+            "Completing allocateExistingUnassignedShards, elapsed time: [{}]",
+            TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startTime)
+        );
         startTime = System.nanoTime();
         shardsAllocator.allocate(allocation);
         logger.debug(

diff --git a/server/src/main/java/org/opensearch/gateway/PrimaryShardBatchAllocator.java b/server/src/main/java/org/opensearch/gateway/PrimaryShardBatchAllocator.java
@@ -12,7 +12,6 @@
 import org.opensearch.cluster.node.DiscoveryNode;
 import org.opensearch.cluster.routing.RoutingNodes;
 import org.opensearch.cluster.routing.ShardRouting;
-import org.opensearch.cluster.routing.UnassignedInfo;
 import org.opensearch.cluster.routing.allocation.AllocateUnassignedDecision;
 import org.opensearch.cluster.routing.allocation.RoutingAllocation;
 import org.opensearch.core.index.shard.ShardId;

diff --git a/server/src/main/java/org/opensearch/gateway/ShardsBatchGatewayAllocator.java b/server/src/main/java/org/opensearch/gateway/ShardsBatchGatewayAllocator.java
@@ -252,7 +252,11 @@ protected BatchRunnableExecutor innerAllocateUnassignedBatch(
                     @Override
                     public void onTimeout() {
                         long startTime = System.nanoTime();
-                        primaryBatchShardAllocator.allocateUnassignedBatchOnTimeout(shardsBatch.getBatchedShardRoutings(), allocation, true);
+                        primaryBatchShardAllocator.allocateUnassignedBatchOnTimeout(
+                            shardsBatch.getBatchedShardRoutings(),
+                            allocation,
+                            true
+                        );
                         logger.info(
                             "Time taken to execute allocateUnassignedBatchOnTimeout for unassigned primary batch with id [{}], size : [{}] in this cycle:[{}ms]",
                             shardsBatch.batchId,