Fix call to release refresh listeners on replica shards.

Signed-off-by: Rishikesh1159 <rishireddy1159@gmail.com>
opensearch-project · Mar 9, 2023 · d62aaca · d62aaca
1 parent 6bd0b3d
commit d62aaca
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/index/shard/RefreshListeners.java b/server/src/main/java/org/opensearch/index/shard/RefreshListeners.java
@@ -194,8 +194,8 @@ public boolean addOrNotify(Translog.Location location, Consumer<Boolean> listene
                 return false;
             }
         }
-        // No free slot so force a refresh and call the listener in this thread
-        forceRefresh.run();
+        // No free slot so release existing refresh listeners and call the listener in this thread
+        releaseSeqNoRefreshListeners();
         listener.accept(true);
         return true;
     }