fix bug. task instance not set host(#625)(#525) (#649)

* fix bug. A worker exits, zk listens for an error(#525)

* fix bug. task instance not set host(#625)

* add sub process task log message

escheduler-api/src/main/java/cn/escheduler/api/enums/Status.java

@@ -30,7 +30,7 @@ public enum Status {
 //    DB_OPERATION_ERROR(10005, "database operation error"),
     HDFS_OPERATION_ERROR(10006, "hdfs operation error"),
     UPDATE_FAILED(10007, "updateProcessInstance failed"),
-    TASK_INSTANCE_HOST_NOT_FOUND(10008, "task instance does not set host"),
+    TASK_INSTANCE_HOST_NOT_FOUND(10008, "The task has not yet begun"),
     TENANT_NAME_EXIST(10009, "tenant code already exists"),
     USER_NOT_EXIST(10010, "user {0} not exists"),
     ALERT_GROUP_NOT_EXIST(10011, "alarm group not found"),
@@ -164,6 +164,7 @@ public enum Status {
     PREVIEW_SCHEDULE_ERROR(10139,"preview schedule error"),
     PARSE_TO_CRON_EXPRESSION_ERROR(10140,"parse cron to cron expression error"),
     SCHEDULE_START_TIME_END_TIME_SAME(10141,"The start time must not be the same as the end"),
+    SUB_PROCESS_TASK_HAS_NOT_LOG(10142, "Child process task has not log"),
 
 
     UDF_FUNCTION_NOT_EXIST(20001, "UDF function not found"),

escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java

@@ -294,9 +294,6 @@ public class ZKMasterClient extends AbstractZKClient {
 
 							InterProcessMutex mutexLock = null;
 							try {
-								// handle dead server, add to zk dead server pth
-								handleDeadServer(path, Constants.MASTER_PREFIX, Constants.ADD_ZK_OP);
-
 								if(masterZNode.equals(path)){
 									logger.error("master server({}) of myself dead , stopping...", path);
 									stoppable.stop(String.format("master server(%s) of myself dead , stopping...", path));
@@ -308,6 +305,9 @@ public class ZKMasterClient extends AbstractZKClient {
 								mutexLock = new InterProcessMutex(zkMasterClient.getZkClient(), znodeLock);
 								mutexLock.acquire();
 
+								// handle dead server, add to zk dead server pth
+								handleDeadServer(path, Constants.MASTER_PREFIX, Constants.ADD_ZK_OP);
+
 								String masterHost = getHostByEventDataPath(path);
 								for (int i = 0; i < Constants.ESCHEDULER_WARN_TIMES_FAILOVER;i++) {
 									alertDao.sendServerStopedAlert(1, masterHost, "Master-Server");
@@ -382,15 +382,14 @@ public class ZKMasterClient extends AbstractZKClient {
 
 							InterProcessMutex mutex = null;
 							try {
-
-								// handle dead server
-								handleDeadServer(path, Constants.WORKER_PREFIX, Constants.ADD_ZK_OP);
-
 								// create a distributed lock, and the root node path of the lock space is /escheduler/lock/failover/worker
 								String znodeLock = zkMasterClient.getWorkerFailoverLockPath();
 								mutex = new InterProcessMutex(zkMasterClient.getZkClient(), znodeLock);
 								mutex.acquire();
 
+								// handle dead server
+								handleDeadServer(path, Constants.WORKER_PREFIX, Constants.ADD_ZK_OP);
+
 								String workerHost = getHostByEventDataPath(path);
 								for (int i = 0; i < Constants.ESCHEDULER_WARN_TIMES_FAILOVER;i++) {
 									alertDao.sendServerStopedAlert(1, workerHost, "Worker-Server");