fixing segment name during refresh

RS146BIJAY · Oct 25, 2024 · 7ee03dc · 7ee03dc
1 parent 0d2dde5
commit 7ee03dc
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/index/engine/InternalEngine.java b/server/src/main/java/org/opensearch/index/engine/InternalEngine.java
@@ -2044,7 +2044,11 @@ public void flush(boolean force, boolean waitIfOngoing) throws EngineException {
 
                             try (StandardDirectoryReader r1 = (StandardDirectoryReader) StandardDirectoryReader.open(criteriaBasedIndexWriters.get("400"));
                                  StandardDirectoryReader r2 = (StandardDirectoryReader) StandardDirectoryReader.open(criteriaBasedIndexWriters.get("200"))) {
-                                parentIndexWriter.addIndexes(r1.getSegmentInfos(), r2.getSegmentInfos());
+                                SegmentInfos clientErrorLogSegmentInfos = r1.getSegmentInfos();
+                                SegmentInfos successLogSegmentInfos = r2.getSegmentInfos();
+                                addPrefixToSegmentInfoAttribute(clientErrorLogSegmentInfos, "400");
+                                addPrefixToSegmentInfoAttribute(successLogSegmentInfos, "200");
+                                parentIndexWriter.addIndexes(clientErrorLogSegmentInfos, successLogSegmentInfos);
                             }
                             final Map<String, String> userData = getParentCommitData(translogManager.getTranslogUUID());
                             SegmentInfos latestSegmentInfos = parentIndexWriter.getSegmentInfos();