任务提交失败时注册集群报错bug解决

dlink-admin/src/main/java/com/dlink/job/Job2MysqlHandler.java

@@ -66,13 +66,15 @@ public class Job2MysqlHandler implements JobHandler {
         Job job = JobContextHolder.getJob();
         History history = new History();
         history.setId(job.getId());
+        if(Asserts.isNullString(job.getJobId())){
+            job.setJobId("unknown-"+LocalDateTime.now().toString());
+        }
         history.setJobId(job.getJobId());
         history.setStatus(job.getStatus().ordinal());
         history.setEndTime(job.getEndTime());
         if(job.isUseGateway()){
             history.setJobManagerAddress(job.getJobManagerAddress());
         }
-//        history.setResult(JSONUtil.toJsonStr(job.getResult()));
         if(job.isUseGateway()){
             Cluster cluster = clusterService.registersCluster(Cluster.autoRegistersCluster(job.getJobManagerAddress(),
                     job.getJobId(),job.getJobConfig().getJobName()+ LocalDateTime.now(), job.getType().getLongValue(),

dlink-core/src/main/java/com/dlink/job/JobManager.java

@@ -306,7 +306,7 @@ public class JobManager {
             LocalDateTime now = LocalDateTime.now();
             job.setEndTime(now);
             job.setStatus(Job.JobStatus.FAILED);
-            String error = now.toString() + ":" + "运行语句：\n" + currentSql + " \n时出现异常:" + e.getMessage() + " \n >>>堆栈信息<<<" + resMsg.toString();
+            String error = now.toString() + ":" + "Exception in executing FlinkSQL:\n" + currentSql + " \nError message: " + e.getMessage() + " \n >>> PrintStackTrace <<<" + resMsg.toString();
             job.setError(error);
             failed();
             close();
@@ -430,7 +430,7 @@ public class JobManager {
             LocalDateTime now = LocalDateTime.now();
             job.setEndTime(now);
             job.setStatus(Job.JobStatus.FAILED);
-            String error = now.toString() + ":" + "运行Jar：\n" + config.getGatewayConfig().getAppConfig().getUserJarPath() + " \n时出现异常:" + e.getMessage() + " \n >>>堆栈信息<<<" + resMsg.toString();
+            String error = now.toString() + ":" + "Exception in executing Jar：\n" + config.getGatewayConfig().getAppConfig().getUserJarPath() + " \nError message: " + e.getMessage() + " \n >>> PrintStackTrace <<<" + resMsg.toString();
             job.setError(error);
             failed();
             close();