diff --git a/ml-algorithms/src/main/java/org/opensearch/ml/engine/memory/MLMemoryManager.java b/ml-algorithms/src/main/java/org/opensearch/ml/engine/memory/MLMemoryManager.java index 5e37a67294..89cca22e1a 100644 --- a/ml-algorithms/src/main/java/org/opensearch/ml/engine/memory/MLMemoryManager.java +++ b/ml-algorithms/src/main/java/org/opensearch/ml/engine/memory/MLMemoryManager.java @@ -300,7 +300,7 @@ public void deleteInteraction(String interactionId, ActionListener list bulkRequest.add(new DeleteRequest(indexName, interactionId)); innerGetTraces(interactionId, ActionListener.wrap(traces -> { - traces.forEach(trace-> bulkRequest.add(new DeleteRequest(indexName, trace.getId()))); + traces.forEach(trace -> bulkRequest.add(new DeleteRequest(indexName, trace.getId()))); innerDeleteInteraction(bulkRequest, interactionId, listener); }, e -> { @@ -310,7 +310,7 @@ public void deleteInteraction(String interactionId, ActionListener list } @VisibleForTesting - void innerDeleteInteraction(BulkRequest bulkRequest, String interactionId, ActionListener listener) { + void innerDeleteInteraction(BulkRequest bulkRequest, String interactionId, ActionListener listener) { try (ThreadContext.StoredContext ignored = client.threadPool().getThreadContext().stashContext()) { ActionListener al = ActionListener.wrap(bulkResponse -> { if (bulkResponse != null && bulkResponse.hasFailures()) {