From a259753bfdcdb0d700174221778fafa0470e7c03 Mon Sep 17 00:00:00 2001 From: lenboo Date: Tue, 23 Jul 2019 19:22:31 +0800 Subject: [PATCH] update documents. --- docs/zh_CN/后端部署文档.md | 14 ++++++++++++-- .../master/runner/MasterExecThread.java | 1 + .../server/quartz/ProcessScheduleJob.java | 19 +++---------------- .../server/worker/runner/FetchTaskThread.java | 1 - .../worker/runner/TaskScheduleThread.java | 2 +- 5 files changed, 17 insertions(+), 20 deletions(-) diff --git a/docs/zh_CN/后端部署文档.md b/docs/zh_CN/后端部署文档.md index 4d94279b1a..7cb90857cc 100644 --- a/docs/zh_CN/后端部署文档.md +++ b/docs/zh_CN/后端部署文档.md @@ -159,8 +159,18 @@ install.sh : 一键部署脚本 * 查看目录 -正常编译完后,会在当前目录生成 target/escheduler-{version}/ , 然后参考 - +正常编译完后,会在当前目录生成 `target/escheduler-{version}/` + +```查看目录 + ../ + ├── bin + ├── conf + |—— install.sh + |—— lib + |—— logs + |—— script + |—— sql +``` ### 2.3 系统常用启停服务(服务用途请具体参见《系统架构设计》小节) diff --git a/escheduler-server/src/main/java/cn/escheduler/server/master/runner/MasterExecThread.java b/escheduler-server/src/main/java/cn/escheduler/server/master/runner/MasterExecThread.java index 9ce08d691a..4591ab1c15 100644 --- a/escheduler-server/src/main/java/cn/escheduler/server/master/runner/MasterExecThread.java +++ b/escheduler-server/src/main/java/cn/escheduler/server/master/runner/MasterExecThread.java @@ -277,6 +277,7 @@ public class MasterExecThread implements Runnable { ProcessDag processDag = generateFlowDag(processInstance.getProcessInstanceJson(), startNodeNameList, recoveryNameList, processInstance.getTaskDependType()); if(processDag == null){ + //TODO... logger.error("processDag is null"); return; } diff --git a/escheduler-server/src/main/java/cn/escheduler/server/quartz/ProcessScheduleJob.java b/escheduler-server/src/main/java/cn/escheduler/server/quartz/ProcessScheduleJob.java index 3e546bea7c..8d9abecfc8 100644 --- a/escheduler-server/src/main/java/cn/escheduler/server/quartz/ProcessScheduleJob.java +++ b/escheduler-server/src/main/java/cn/escheduler/server/quartz/ProcessScheduleJob.java @@ -78,6 +78,7 @@ public class ProcessScheduleJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { + //TODO... Assert.notNull(processDao, "please call init() method first"); JobDataMap dataMap = context.getJobDetail().getJobDataMap(); @@ -85,24 +86,10 @@ public class ProcessScheduleJob implements Job { int projectId = dataMap.getInt(Constants.PROJECT_ID); int scheduleId = dataMap.getInt(Constants.SCHEDULE_ID); - /** - * The scheduled time the trigger fired for. For instance the scheduled - * time may have been 10:00:00 but the actual fire time may have been - * 10:00:03 if the scheduler was too busy. - * - * @return Returns the scheduledFireTime. - * @see #getFireTime() - */ + Date scheduledFireTime = context.getScheduledFireTime(); - /** - * The actual time the trigger fired. For instance the scheduled time may - * have been 10:00:00 but the actual fire time may have been 10:00:03 if - * the scheduler was too busy. - * - * @return Returns the fireTime. - * @see #getScheduledFireTime() - */ + Date fireTime = context.getFireTime(); logger.info("scheduled fire time :{}, fire time :{}, process id :{}", scheduledFireTime, fireTime, scheduleId); diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java index de4666d102..5495096161 100644 --- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java +++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java @@ -128,7 +128,6 @@ public class FetchTaskThread implements Runnable{ while (Stopper.isRunning()){ InterProcessMutex mutex = null; try { - ThreadPoolExecutor poolExecutor = (ThreadPoolExecutor) workerExecService; //check memory and cpu usage and threads diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java index 89226bf8b5..f1b4265e30 100644 --- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java +++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/TaskScheduleThread.java @@ -252,7 +252,7 @@ public class TaskScheduleThread implements Callable { } } }catch (Exception e){ - logger.error("task escheduler failure : " + e.getMessage(),e); + logger.error("task escheduler failure : ", e); status = ExecutionStatus.FAILURE ; logger.error(String.format("task process exception, process id : %s , task : %s", taskInstance.getProcessInstanceId(),