fix method reference

Signed-off-by: Shivansh Arora <[email protected]>
shiv0408 · Mar 14, 2024 · 7237756 · 7237756
1 parent a6a6b28
commit 7237756
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/gateway/ReplicaShardBatchAllocator.java b/server/src/main/java/org/opensearch/gateway/ReplicaShardBatchAllocator.java
@@ -87,7 +87,7 @@ public void processExistingRecoveries(RoutingAllocation allocation, List<List<Sh
             for (ShardRouting shard : eligibleShards) {
                 Map<DiscoveryNode, StoreFilesMetadata> nodeShardStores = convertToNodeStoreFilesMetadataMap(shard, shardState);
 
-                Runnable cancellationAction = getShardCancellationAction(shard, allocation, nodeShardStores);
+                Runnable cancellationAction = cancelExistingRecoveryForBetterMatch(shard, allocation, nodeShardStores);
                 if (cancellationAction != null) {
                     shardCancellationActions.add(cancellationAction);
                 }