add missing changes

jimczi · Dec 5, 2024 · a3242f5 · a3242f5
1 parent 9a32666
commit a3242f5
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 6 deletions.
diff --git a/server/src/main/java/org/elasticsearch/index/engine/Engine.java b/server/src/main/java/org/elasticsearch/index/engine/Engine.java
@@ -947,12 +947,12 @@ public boolean allowSearchIdleOptimization() {
      */
     @Deprecated
     public abstract Translog.Snapshot newChangesSnapshot(
-            String source,
-            long fromSeqNo,
-            long toSeqNo,
-            boolean requiredFullRange,
-            boolean singleConsumer,
-            boolean accessStats
+        String source,
+        long fromSeqNo,
+        long toSeqNo,
+        boolean requiredFullRange,
+        boolean singleConsumer,
+        boolean accessStats
     ) throws IOException;
 
     /**

diff --git a/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java
@@ -3136,6 +3136,18 @@ public int countChanges(String source, long fromSeqNo, long toSeqNo) throws IOEx
         }
     }
 
+    @Override
+    public Translog.Snapshot newChangesSnapshot(
+        String source,
+        long fromSeqNo,
+        long toSeqNo,
+        boolean requiredFullRange,
+        boolean singleConsumer,
+        boolean accessStats
+    ) throws IOException {
+        return newChangesSnapshot(source, fromSeqNo, toSeqNo, requiredFullRange, singleConsumer, accessStats, 0);
+    }
+
     @Override
     public Translog.Snapshot newChangesSnapshot(
         String source,

diff --git a/server/src/main/java/org/elasticsearch/index/engine/ReadOnlyEngine.java b/server/src/main/java/org/elasticsearch/index/engine/ReadOnlyEngine.java
@@ -361,6 +361,18 @@ public int countChanges(String source, long fromSeqNo, long toSeqNo) throws IOEx
         }
     }
 
+    @Override
+    public Translog.Snapshot newChangesSnapshot(
+        String source,
+        long fromSeqNo,
+        long toSeqNo,
+        boolean requiredFullRange,
+        boolean singleConsumer,
+        boolean accessStats
+    ) throws IOException {
+        return Translog.Snapshot.EMPTY;
+    }
+
     @Override
     public Translog.Snapshot newChangesSnapshot(
         String source,