Swallow exception in deleteTranslogFilesAsync to prevent shard failure

Signed-off-by: Gaurav Bafna <gbbafna@amazon.com>
opensearch-project · Feb 9, 2024 · 699b571 · 699b571
1 parent 50dcbf2
commit 699b571
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/index/translog/transfer/TranslogTransferManager.java b/server/src/main/java/org/opensearch/index/translog/transfer/TranslogTransferManager.java
@@ -555,7 +555,14 @@ public void onFailure(Exception e) {
             );
         } catch (Exception e) {
             onCompletion.run();
-            throw e;
+            logger.error(
+                () -> new ParameterizedMessage(
+                    "Exception occurred while deleting translog for primaryTerm={} files={}",
+                    primaryTerm,
+                    files
+                ),
+                e
+            );
         }
     }