From a6cc76e81c1d590360bd303c45e35b346cff73ac Mon Sep 17 00:00:00 2001 From: zane-neo Date: Fri, 5 Jul 2024 10:06:19 +0800 Subject: [PATCH] format code Signed-off-by: zane-neo --- .../ml/action/undeploy/TransportUndeployModelAction.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/plugin/src/main/java/org/opensearch/ml/action/undeploy/TransportUndeployModelAction.java b/plugin/src/main/java/org/opensearch/ml/action/undeploy/TransportUndeployModelAction.java index 52d83ce767..3281b72494 100644 --- a/plugin/src/main/java/org/opensearch/ml/action/undeploy/TransportUndeployModelAction.java +++ b/plugin/src/main/java/org/opensearch/ml/action/undeploy/TransportUndeployModelAction.java @@ -113,7 +113,7 @@ protected MLUndeployModelNodesResponse newResponse( // when undeploy a undeployed model, the entry.getvalue() is null if (entry.getValue() != null && (!modelWorkNodesBeforeRemoval.containsKey(entry.getKey()) - || modelWorkNodesBeforeRemoval.get(entry.getKey()).length < entry.getValue().length)) { + || modelWorkNodesBeforeRemoval.get(entry.getKey()).length < entry.getValue().length)) { modelWorkNodesBeforeRemoval.put(entry.getKey(), entry.getValue()); } } @@ -202,7 +202,10 @@ protected MLUndeployModelNodesResponse newResponse( try { boolean success = countDownLatch.await(1000, TimeUnit.MILLISECONDS); if (!success) { - log.error("Failed to update model state as undeployed in model index after waiting for 1 second, please check model status manually"); + log + .error( + "Failed to update model state as undeployed in model index after waiting for 1 second, please check model status manually" + ); } } catch (InterruptedException e) { Thread.currentThread().interrupt();