diff --git a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/ConnectorUtils.java b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/ConnectorUtils.java index 539fb53a20..8b6d310283 100644 --- a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/ConnectorUtils.java +++ b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/ConnectorUtils.java @@ -27,7 +27,6 @@ import org.apache.commons.lang3.StringUtils; import org.apache.commons.text.StringSubstitutor; -import org.opensearch.core.rest.RestStatus; import org.opensearch.ml.common.connector.Connector; import org.opensearch.ml.common.connector.ConnectorAction; import org.opensearch.ml.common.connector.MLPostProcessFunction; diff --git a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/MLSdkAsyncHttpResponseHandler.java b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/MLSdkAsyncHttpResponseHandler.java index 5ca92fb509..388ba7bbcf 100644 --- a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/MLSdkAsyncHttpResponseHandler.java +++ b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/remote/MLSdkAsyncHttpResponseHandler.java @@ -158,7 +158,8 @@ private void reOrderTensorResponses(Map tensorOutputs) { // either one fails, we will return a failure response. OpenSearchStatusException openSearchStatusException = null; for (Map.Entry entry : sortedMap.entrySet()) { - if (entry.getValue().getStatusCode() < HttpStatus.SC_OK || entry.getValue().getStatusCode() > HttpStatus.SC_MULTIPLE_CHOICES) { + if (entry.getValue().getStatusCode() < HttpStatus.SC_OK + || entry.getValue().getStatusCode() > HttpStatus.SC_MULTIPLE_CHOICES) { openSearchStatusException = buildOpenSearchStatusException(entry.getValue()); break; }