Remove deletion logic causing read issues due to deleted segments_N

Signed-off-by: Suraj Singh <surajrider@gmail.com>
opensearch-project · Aug 1, 2023 · 4e79a05 · 4e79a05
1 parent 21c71d8
commit 4e79a05
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/server/src/main/java/org/opensearch/index/shard/IndexShard.java b/server/src/main/java/org/opensearch/index/shard/IndexShard.java
@@ -4659,15 +4659,6 @@ public void syncSegmentsFromRemoteSegmentStore(boolean overrideLocal, boolean re
                     );
                     long processedLocalCheckpoint = Long.parseLong(infosSnapshot.getUserData().get(LOCAL_CHECKPOINT_KEY));
                     store.commitSegmentInfos(infosSnapshot, processedLocalCheckpoint, processedLocalCheckpoint);
-                    Collection<String> currentInfoFiles = infosSnapshot.files(true);
-                    // For recovering shards, clean up un-usable incremental refresh files and commit points.
-                    if (state() != IndexShardState.STARTED) {
-                        for (String localFile : storeDirectory.listAll()) {
-                            if (Store.isAutogenerated(localFile) == false && currentInfoFiles.contains(localFile) == false) {
-                                storeDirectory.deleteFile(localFile);
-                            }
-                        }
-                    }
                 }
             }
         } catch (IOException e) {