Revert "[ML][backport] Warn for model load failures if they have a st…

…atus code <500" This reverts commit e5b5b6e.
elastic · Sep 23, 2024 · f93678d · f93678d
1 parent e5b5b6e
commit f93678d
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/...va/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java b/...va/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java
@@ -9,7 +9,6 @@
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
-import org.elasticsearch.ElasticsearchException;
 import org.elasticsearch.ResourceNotFoundException;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.search.SearchPhaseExecutionException;
@@ -755,12 +754,6 @@ private void updateStoredState(String deploymentId, RoutingInfoUpdate update, Ac
 
     private void handleLoadFailure(TrainedModelDeploymentTask task, Exception ex) {
         logger.error(() -> "[" + task.getDeploymentId() + "] model [" + task.getParams().getModelId() + "] failed to load", ex);
-    private void handleLoadFailure(TrainedModelDeploymentTask task, Exception ex, ActionListener<Boolean> retryListener) {
-        if (ex instanceof ElasticsearchException esEx && esEx.status().getStatus() < 500) {
-            logger.warn(() -> "[" + task.getDeploymentId() + "] model [" + task.getParams().getModelId() + "] failed to load", ex);
-        } else {
-            logger.error(() -> "[" + task.getDeploymentId() + "] model [" + task.getParams().getModelId() + "] failed to load", ex);
-        }
         if (task.isStopped()) {
             logger.debug(
                 () -> format(