diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java index 88da235ff001c200090b7976a2aece921d7c1b23..6c871623543cf8de21b1edc2c065d7028fab63f0 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java @@ -86,11 +86,11 @@ public class MlflowTask extends AbstractTaskExecutor { // construct process String command = buildCommand(); TaskResponse commandExecuteResult = shellCommandExecutor.run(command); - int exitCode = exitStatusCode; + int exitCode; if (mlflowParameters.getIsDeployDocker()){ exitCode = checkDockerHealth(); }else { - exitCode = getExitStatusCode(); + exitCode = commandExecuteResult.getExitStatusCode(); } setExitStatusCode(exitCode); setAppIds(commandExecuteResult.getAppIds());