put Math.min(maxSeqNo, lastRefreshedCheckpoint) in max_seq_no

Signed-off-by: guojialiang <[email protected]>

Author: guojialiang92

server/src/main/java/org/opensearch/index/engine/InternalEngine.java

@@ -269,10 +269,7 @@ public void onAfterTranslogSync() {
 
                     @Override
                     public void onAfterTranslogRecovery() {
-                        // In the scenario of vanilla segment replication, the force parameter is used to ensure that the
-                        // SegmentInfos#version of the primary shard is greater than or equal to that of the replicas.
-                        boolean isForceFlush = engineConfig.getIndexSettings().isSegRepLocalEnabled();
-                        flush(isForceFlush, true);
+                        flush(false, true);
                         translogManager.trimUnreferencedTranslogFiles();
                     }
 

server/src/main/java/org/opensearch/indices/replication/common/CopyState.java

@@ -23,8 +23,6 @@
 import java.io.UncheckedIOException;
 import java.util.Map;
 
-import static org.opensearch.index.seqno.SequenceNumbers.LOCAL_CHECKPOINT_KEY;
-
 /**
  * An Opensearch-specific version of Lucene's CopyState class that
  * holds incRef'd file level details for one point-in-time segment infos.
@@ -50,8 +48,8 @@ public CopyState(IndexShard shard) throws IOException {
 
         SegmentInfos segmentInfosSnapshot = segmentInfos.clone();
         Map<String, String> userData = segmentInfosSnapshot.getUserData();
-        userData.put(LOCAL_CHECKPOINT_KEY, String.valueOf(lastRefreshedCheckpoint));
-        userData.put(SequenceNumbers.MAX_SEQ_NO, Long.toString(lastRefreshedCheckpoint));
+        long maxSeqNo = Long.parseLong(userData.get(SequenceNumbers.MAX_SEQ_NO));
+        userData.put(SequenceNumbers.MAX_SEQ_NO, Long.toString(Math.min(maxSeqNo, lastRefreshedCheckpoint)));
         segmentInfosSnapshot.setUserData(userData, false);
 
         ByteBuffersDataOutput buffer = new ByteBuffersDataOutput();