Fixing error in ReadOnlyEngineTests by casting.

Signed-off-by: Rishikesh1159 <rishireddy1159@gmail.com>
opensearch-project · Aug 5, 2022 · 8b82ff6 · 8b82ff6
1 parent 47c518d
commit 8b82ff6
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/server/src/test/java/org/opensearch/index/engine/ReadOnlyEngineTests.java b/server/src/test/java/org/opensearch/index/engine/ReadOnlyEngineTests.java
@@ -107,7 +107,10 @@ public void testReadOnlyEngine() throws Exception {
                 lastSeqNoStats = engine.getSeqNoStats(globalCheckpoint.get());
                 lastDocIds = getDocIds(engine, true);
                 assertThat(readOnlyEngine.getPersistedLocalCheckpoint(), equalTo(lastSeqNoStats.getLocalCheckpoint()));
-                assertThat(readOnlyEngine.getProcessedLocalCheckpoint(), equalTo(readOnlyEngine.getPersistedLocalCheckpoint()));
+                assertThat(
+                    ((ReadOnlyEngine) readOnlyEngine).getProcessedLocalCheckpoint(),
+                    equalTo(readOnlyEngine.getPersistedLocalCheckpoint())
+                );
                 assertThat(readOnlyEngine.getSeqNoStats(globalCheckpoint.get()).getMaxSeqNo(), equalTo(lastSeqNoStats.getMaxSeqNo()));
                 assertThat(getDocIds(readOnlyEngine, false), equalTo(lastDocIds));
                 for (int i = 0; i < numDocs; i++) {
@@ -132,7 +135,10 @@ public void testReadOnlyEngine() throws Exception {
                 IOUtils.close(external, internal);
                 // the locked down engine should still point to the previous commit
                 assertThat(readOnlyEngine.getPersistedLocalCheckpoint(), equalTo(lastSeqNoStats.getLocalCheckpoint()));
-                assertThat(readOnlyEngine.getProcessedLocalCheckpoint(), equalTo(readOnlyEngine.getPersistedLocalCheckpoint()));
+                assertThat(
+                    ((ReadOnlyEngine) readOnlyEngine).getProcessedLocalCheckpoint(),
+                    equalTo(readOnlyEngine.getPersistedLocalCheckpoint())
+                );
                 assertThat(readOnlyEngine.getSeqNoStats(globalCheckpoint.get()).getMaxSeqNo(), equalTo(lastSeqNoStats.getMaxSeqNo()));
                 assertThat(getDocIds(readOnlyEngine, false), equalTo(lastDocIds));
                 try (Engine.GetResult getResult = readOnlyEngine.get(get, readOnlyEngine::acquireSearcher)) {
@@ -146,7 +152,10 @@ public void testReadOnlyEngine() throws Exception {
                     .recoverFromTranslog(translogHandler, recoveringEngine.getProcessedLocalCheckpoint(), Long.MAX_VALUE);
                 // the locked down engine should still point to the previous commit
                 assertThat(readOnlyEngine.getPersistedLocalCheckpoint(), equalTo(lastSeqNoStats.getLocalCheckpoint()));
-                assertThat(readOnlyEngine.getProcessedLocalCheckpoint(), equalTo(readOnlyEngine.getPersistedLocalCheckpoint()));
+                assertThat(
+                    ((ReadOnlyEngine) readOnlyEngine).getProcessedLocalCheckpoint(),
+                    equalTo(readOnlyEngine.getPersistedLocalCheckpoint())
+                );
                 assertThat(readOnlyEngine.getSeqNoStats(globalCheckpoint.get()).getMaxSeqNo(), equalTo(lastSeqNoStats.getMaxSeqNo()));
                 assertThat(getDocIds(readOnlyEngine, false), equalTo(lastDocIds));
             }