未验证 提交 e99b5ac6 编写于 作者: L lgcareer 提交者: GitHub

Merge pull request #571 from lgcareer/branch-1.0.2

fix bug 569 to resolve schedule doesn't really stop
...@@ -487,7 +487,7 @@ public class ProcessDefinitionService extends BaseDAGService { ...@@ -487,7 +487,7 @@ public class ProcessDefinitionService extends BaseDAGService {
// set status // set status
schedule.setReleaseState(ReleaseState.OFFLINE); schedule.setReleaseState(ReleaseState.OFFLINE);
scheduleMapper.update(schedule); scheduleMapper.update(schedule);
deleteSchedule(project.getId(), id); deleteSchedule(project.getId(), schedule.getId());
} }
break; break;
} }
......
...@@ -442,14 +442,14 @@ public class SchedulerService extends BaseService { ...@@ -442,14 +442,14 @@ public class SchedulerService extends BaseService {
/** /**
* delete schedule * delete schedule
*/ */
public static void deleteSchedule(int projectId, int processId) throws RuntimeException{ public static void deleteSchedule(int projectId, int scheduleId) throws RuntimeException{
logger.info("delete schedules of project id:{}, flow id:{}", projectId, processId); logger.info("delete schedules of project id:{}, schedule id:{}", projectId, scheduleId);
String jobName = QuartzExecutors.buildJobName(processId); String jobName = QuartzExecutors.buildJobName(scheduleId);
String jobGroupName = QuartzExecutors.buildJobGroupName(projectId); String jobGroupName = QuartzExecutors.buildJobGroupName(projectId);
if(!QuartzExecutors.getInstance().deleteJob(jobName, jobGroupName)){ if(!QuartzExecutors.getInstance().deleteJob(jobName, jobGroupName)){
logger.warn("set offline failure:projectId:{},processId:{}",projectId,processId); logger.warn("set offline failure:projectId:{},scheduleId:{}",projectId,scheduleId);
throw new RuntimeException(String.format("set offline failure")); throw new RuntimeException(String.format("set offline failure"));
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册