Commit ce4a3003 by huangfusuper

分布式锁

parent 9fac0731
...@@ -110,7 +110,7 @@ public class RunRecordingServiceImpl implements RunRecordingService { ...@@ -110,7 +110,7 @@ public class RunRecordingServiceImpl implements RunRecordingService {
//判断当前的实例 中是否有 未完成的 //判断当前的实例 中是否有 未完成的
if (RunRecordingEnum.FLOW_STATUS_RUN_ING.getCode().equals(runRecording.getFlowStatus()) || if (RunRecordingEnum.FLOW_STATUS_RUN_ING.getCode().equals(runRecording.getFlowStatus()) ||
RunRecordingEnum.FLOW_STATUS_IS_STOP.getCode().equals(runRecording.getFlowStatus())) { RunRecordingEnum.FLOW_STATUS_IS_STOP.getCode().equals(runRecording.getFlowStatus())) {
log.info("----------{}实例正在运行中--------",runRecording); log.debug("----------{}实例正在运行中--------",runRecording);
return true; return true;
} }
} }
......
...@@ -66,7 +66,7 @@ public class MakeUpFlowThreadRunHelper extends BaseThreadRunHelper { ...@@ -66,7 +66,7 @@ public class MakeUpFlowThreadRunHelper extends BaseThreadRunHelper {
runRecordingAndJobTaskService.updateRunRecordingAndTask(value); runRecordingAndJobTaskService.updateRunRecordingAndTask(value);
} }
} }
log.info("com.byit.thread.helper.MakeUpFlowThreadRunHelper.start 执行完成");
return UNIVERSAL_WAIT_TIME; return UNIVERSAL_WAIT_TIME;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment