Fix StoreRecovery

Signed-off-by: Sachin Kale <[email protected]>
sachinpkale · Sep 5, 2024 · 00b0f2c · 00b0f2c
1 parent fcec555
commit 00b0f2c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/index/shard/StoreRecovery.java b/server/src/main/java/org/opensearch/index/shard/StoreRecovery.java
@@ -57,6 +57,7 @@
 import org.opensearch.core.index.shard.ShardId;
 import org.opensearch.index.engine.Engine;
 import org.opensearch.index.engine.EngineException;
+import org.opensearch.index.engine.InternalEngine;
 import org.opensearch.index.mapper.MapperService;
 import org.opensearch.index.remote.RemoteStorePathStrategy;
 import org.opensearch.index.remote.RemoteStoreUtils;
@@ -525,8 +526,8 @@ void recoverShallowSnapshotV2(
                     indexShard.postRecovery("post recovery from remote_store");
                     SegmentInfos committedSegmentInfos = indexShard.store().readLastCommittedSegmentsInfo();
                     try {
-                        indexShard.getEngine()
-                            .translogManager()
+                        assert indexShard.getEngine() instanceof InternalEngine;
+                        ((InternalEngine) indexShard.getEngine()).translogManager()
                             .setMinSeqNoToKeep(Long.parseLong(committedSegmentInfos.getUserData().get(SequenceNumbers.MAX_SEQ_NO)) + 1);
                     } catch (IllegalArgumentException e) {
                         logger.warn("MinSeqNoToKeep is already past the maxSeqNo from commited segment infos");