Mark clearShard method as synchronized

Signed-off-by: Aman Khare <amkhar@amazon.com>
opensearch-project · Apr 10, 2024 · 08763ed · 08763ed
1 parent 65229fc
commit 08763ed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/gateway/AsyncShardBatchFetch.java b/server/src/main/java/org/opensearch/gateway/AsyncShardBatchFetch.java
@@ -75,7 +75,7 @@ public abstract class AsyncShardBatchFetch<T extends BaseNodeResponse, V> extend
      *
      * @param shardId shardId to be removed from the batch.
      */
-    public void clearShard(ShardId shardId) {
+    public synchronized void clearShard(ShardId shardId) {
         this.shardAttributesMap.remove(shardId);
         this.cache.deleteShard(shardId);
     }