diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
index 6c4356fe968149015c117775179b48ebe25d269a..36e2b60d18804daeb5449cab75ad97f56baa2d85 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java
@@ -325,8 +325,15 @@ public class ProcessService {
             if (StringUtils.isEmpty(taskInstance.getHost())){
                 continue;
             }
-            String ip = Host.of(taskInstance.getHost()).getIp();
             int port = Constants.RPC_PORT;
+            String ip = "";
+            try {
+                ip = Host.of(taskInstance.getHost()).getIp();
+            }catch (Exception e){
+                // compatible old version
+                ip = taskInstance.getHost();
+            }
+
 
             // remove task log from loggerserver
             logClient.removeTaskLog(ip,port,taskLogPath);