From 6e051cca77e74668215a053dc6adfa66b74d4565 Mon Sep 17 00:00:00 2001 From: Hailong Cui Date: Wed, 29 Nov 2023 17:48:09 +0800 Subject: [PATCH] fix spotless Signed-off-by: Hailong Cui --- .../java/org/opensearch/ml/engine/memory/MLMemoryManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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()) {