Build failure fix

Signed-off-by: Shivansh Arora <shivansh.arora@protonmail.com>
shiv0408 · Sep 15, 2023 · e7c778c · e7c778c
1 parent 35d59ff
commit e7c778c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/BaseGatewayShardAllocator.java b/server/src/main/java/org/opensearch/gateway/BaseGatewayShardAllocator.java
@@ -50,7 +50,7 @@
 /**
  * An abstract class that implements basic functionality for allocating
  * shards to nodes based on shard copies that already exist in the cluster.
- * <p>
+ *
  * Individual implementations of this class are responsible for providing
  * the logic to determine to which nodes (if any) those shards are allocated.
  *
@@ -64,9 +64,8 @@ public abstract class BaseGatewayShardAllocator {
      * Allocate an unassigned shard to nodes (if any) where valid copies of the shard already exist.
      * It is up to the individual implementations of {@link #makeAllocationDecision(ShardRouting, RoutingAllocation, Logger)}
      * to make decisions on assigning shards to nodes.
-     *
-     * @param shardRouting                the shard to allocate
-     * @param allocation                  the allocation state container object
+     * @param shardRouting the shard to allocate
+     * @param allocation the allocation state container object
      * @param unassignedAllocationHandler handles the allocation of the current shard
      */
     public void allocateUnassigned(
@@ -110,9 +109,9 @@ protected long getExpectedShardSize(ShardRouting shardRouting, RoutingAllocation
      * {@link #allocateUnassigned(ShardRouting, RoutingAllocation, ExistingShardsAllocator.UnassignedAllocationHandler)} to make decisions
      * about whether or not the shard can be allocated by this allocator and if so, to which node it will be allocated.
      *
-     * @param unassignedShard the unassigned shard to allocate
-     * @param allocation      the current routing state
-     * @param logger          the logger
+     * @param unassignedShard  the unassigned shard to allocate
+     * @param allocation       the current routing state
+     * @param logger           the logger
      * @return an {@link AllocateUnassignedDecision} with the final decision of whether to allocate and details of the decision
      */
     public abstract AllocateUnassignedDecision makeAllocationDecision(

diff --git a/server/src/main/java/org/opensearch/gateway/PrimaryShardAllocator.java b/server/src/main/java/org/opensearch/gateway/PrimaryShardAllocator.java
@@ -150,8 +150,7 @@ private static NodeShardStates adaptToNodeShardStates(FetchResult<NodeGatewaySta
                     nodeGatewayStartedShard.primary(),
                     nodeGatewayStartedShard.replicationCheckpoint(),
                     nodeGatewayStartedShard.storeException()
-                ),
-                node
+                )
             );
         });
         return nodeShardStates;
@@ -425,7 +424,7 @@ protected NodeShardsResult buildNodeShardsResult(
                         + nodeShardState.storeException();
                 numberOfAllocationsFound++;
                 if (matchAnyShard || inSyncAllocationIds.contains(nodeShardState.allocationId())) {
-                    nodeShardStates.add(nodeShardState, nodeShardState.getNode());
+                    nodeShardStates.add(nodeShardState);
                 }
             }
         }