异常信息

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/RunNodeServiceImpl.java

 package com.byit.service.impl;
 
 import com.byit.enums.NodeNameEnum;
+import com.byit.enums.ScheduleTypeEnum;
 import com.byit.event.FlowScanEndEvent;
 import com.byit.job.utils.CronExpression;
 import com.byit.model.Flow;
@@ -90,6 +91,7 @@ public class RunNodeServiceImpl implements RunNodeServer, ApplicationEventPublis
             }
             jobTask.setRunId(runId);
             jobTask.setFlowName(flow.getFlowName());
+            jobTask.setScheduleType(ScheduleTypeEnum.NORMAL.getCode());
             //如果不是开始节点
             if(!NodeNameEnum.START_NODE.getNodeName().equals(jobTask.getNodeName())){
                 List<Integer> dependIdByNodeId = nodeDependencyService.findDependIdByNodeId(jobTask.getNodeId());

byit-myth-core/myth-admin-core/src/main/java/com/byit/task/JavaNodeExecutorTask.java

@@ -100,7 +100,7 @@ public class JavaNodeExecutorTask  implements TimerTask {
             jobTaskRunLogById.setAlertEnd("1");
 
         }catch (Exception e){
-            if (mythJobTaskSchedule.getScheduleType().equals(4)) {
+            if (mythJobTaskSchedule.getScheduleType() == 4) {
                 StringRedisTemplate stringRedisTemplate = (StringRedisTemplate) SpringUtil.getBean("stringRedisTemplate");
                 RunLog runLog = RunLog.builder().isEnd(true).isSuccess(false).runLog("执行资源异常" +  MythLogUtils.getMessage(e)).build();
                 //stringRedisTemplate.convertAndSend("REAL:EXEC:" + mythJobTaskSchedule.getLogId() , JSON.toJSONString(runLog, WriteClassName));