Browse Source

[BUG-11181] [Document] text check (#11183)

3.1.0-release
fuchanghai 2 years ago committed by GitHub
parent
commit
d73ad2e7d5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 3
      docs/docs/zh/development/architecture-design.md
  2. 9
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java

3
docs/docs/zh/development/architecture-design.md

@ -206,7 +206,7 @@ Master Scheduler线程一旦发现任务实例为” 需要容错”状态,则
- 一种是业务节点,这种节点都对应一个实际的脚本或者处理语句,比如Shell节点,MR节点、Spark节点、依赖节点等。 - 一种是业务节点,这种节点都对应一个实际的脚本或者处理语句,比如Shell节点,MR节点、Spark节点、依赖节点等。
- 还有一种是逻辑节点,这种节点不做实际的脚本或语句处理,只是整个流程流转的逻辑处理,比如子流程节等。 - 还有一种是逻辑节点,这种节点不做实际的脚本或语句处理,只是整个流程流转的逻辑处理,比如子流程节等。
每一个**业务节点**都可以配置失败重试的次数,当该任务节点失败,会自动重试,直到成功或者超过配置的重试次数。**逻辑节点**不支持失败重试。但是逻辑节点里的任务支持重试。 每一个**业务节点**都可以配置失败重试的次数,当该任务节点失败,会自动重试,直到成功或者超过配置的重试次数。**逻辑节点**不支持失败重试。但是逻辑节点里的任务支持重试。
@ -299,4 +299,3 @@ public class TaskLogFilter extends Filter<ILoggingEvent> {
### 总结 ### 总结
本文从调度出发,初步介绍了大数据分布式工作流调度系统--DolphinScheduler的架构原理及实现思路。未完待续 本文从调度出发,初步介绍了大数据分布式工作流调度系统--DolphinScheduler的架构原理及实现思路。未完待续

9
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java

@ -294,7 +294,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
} }
/** /**
* check if the current process has subprocesses and all subprocesses are valid * check whether the current process has subprocesses and validate all subprocesses
* *
* @param processDefinition * @param processDefinition
* @return check result * @return check result
@ -607,7 +607,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
} }
/** /**
* check if sub processes are offline before starting process definition * check whether sub processes are offline before starting process definition
* *
* @param processDefinitionCode process definition code * @param processDefinitionCode process definition code
* @return check result code * @return check result code
@ -724,8 +724,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
return createComplementCommandList(schedule, runMode, command, expectedParallelismNumber, return createComplementCommandList(schedule, runMode, command, expectedParallelismNumber,
complementDependentMode); complementDependentMode);
} catch (CronParseException cronParseException) { } catch (CronParseException cronParseException) {
// this just make compile happy, since we already validate the cron before // We catch the exception here just to make compiler happy, since we have already validated the schedule cron expression before
logger.error("Parse cron error", cronParseException);
return 0; return 0;
} }
} else { } else {
@ -940,7 +939,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
/** /**
* @param schedule * @param schedule
* @return check error return 0 otherwish 1 * @return check error return 0, otherwise 1
*/ */
private boolean isValidateScheduleTime(String schedule) { private boolean isValidateScheduleTime(String schedule) {
Map<String, String> scheduleResult = JSONUtils.toMap(schedule); Map<String, String> scheduleResult = JSONUtils.toMap(schedule);

Loading…
Cancel
Save