Fix opensearch-project#5844

Signed-off-by: Ashish Singh <ssashish@amazon.com>
ashking94 · Jan 13, 2023 · 5322ad9 · 5322ad9
1 parent 15adb36
commit 5322ad9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java b/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java
@@ -89,7 +89,7 @@ public void beforeRefresh() throws IOException {
     public void afterRefresh(boolean didRefresh) {
         synchronized (this) {
             try {
-                if (indexShard.shardRouting.primary()) {
+                if (indexShard.getReplicationTracker().isPrimaryMode()) {
                     if (this.primaryTerm != indexShard.getOperationPrimaryTerm()) {
                         this.primaryTerm = indexShard.getOperationPrimaryTerm();
                         this.remoteDirectory.init();