You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ja...@apache.org on 2020/08/19 03:40:38 UTC
[incubator-dolphinscheduler] branch dev updated (00e0003 -> a4ee351)
This is an automated email from the ASF dual-hosted git repository.
jave pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
from 00e0003 [test-2995][e2e]Add task connection (#3524)
add a4ee351 delay execution of tasks and improve some designs (#3427)
No new revisions were added by this update.
Summary of changes:
.../dolphinscheduler/api/dto/TaskCountDto.java | 24 +-
.../apache/dolphinscheduler/common/Constants.java | 17 +-
.../common/enums/ExecutionStatus.java | 109 ++---
.../common/enums/TaskStateType.java | 10 +-
.../dolphinscheduler/common/model/TaskNode.java | 50 ++-
.../dolphinscheduler/common/utils/DateUtils.java | 444 ++++++++++++++++++++-
.../common/enums/ExecutionStatusTest.java} | 23 +-
.../dolphinscheduler/dao/entity/TaskInstance.java | 127 +++---
.../remote/codec/NettyDecoder.java | 1 +
.../builder/TaskExecutionContextBuilder.java | 2 +
.../server/entity/TaskExecutionContext.java | 171 +++++---
.../master/runner/ConditionsTaskExecThread.java | 1 +
.../master/runner/DependentTaskExecThread.java | 1 +
.../master/runner/MasterBaseTaskExecThread.java | 21 +-
.../server/master/runner/MasterExecThread.java | 54 ++-
.../server/master/runner/MasterTaskExecThread.java | 17 +-
.../worker/processor/TaskExecuteProcessor.java | 39 +-
.../server/worker/runner/TaskExecuteThread.java | 98 ++++-
.../worker/task/AbstractCommandExecutor.java | 22 +-
.../consumer/TaskPriorityQueueConsumerTest.java | 3 +-
.../master/dispatch/ExecutorDispatcherTest.java | 3 +-
.../executor/NettyExecutorManagerTest.java | 3 +-
.../dispatch/host/RoundRobinHostManagerTest.java | 3 +-
.../processor/queue/TaskResponseServiceTest.java | 4 +-
.../server/master/registry/MasterRegistryTest.java | 4 +-
.../worker/runner/TaskExecuteThreadTest.java | 171 ++++++++
.../service/process/ProcessService.java | 98 ++++-
pom.xml | 2 +
sql/dolphinscheduler-postgre.sql | 4 +-
sql/dolphinscheduler_mysql.sql | 2 +
.../1.3.0_schema/mysql/dolphinscheduler_ddl.sql | 1 -
.../mysql/dolphinscheduler_ddl.sql | 34 +-
.../mysql}/dolphinscheduler_dml.sql | 2 +-
.../postgresql/dolphinscheduler_ddl.sql | 52 +++
.../postgresql/dolphinscheduler_dml.sql | 2 +-
35 files changed, 1290 insertions(+), 329 deletions(-)
copy dolphinscheduler-common/src/{main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java => test/java/org/apache/dolphinscheduler/common/enums/ExecutionStatusTest.java} (70%)
create mode 100644 dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThreadTest.java
copy sql/upgrade/{1.0.1_schema => 1.3.3_schema}/mysql/dolphinscheduler_ddl.sql (53%)
copy sql/upgrade/{1.2.0_schema/postgresql => 1.3.3_schema/mysql}/dolphinscheduler_dml.sql (99%)
create mode 100644 sql/upgrade/1.3.3_schema/postgresql/dolphinscheduler_ddl.sql
copy sql/upgrade/{1.2.0_schema => 1.3.3_schema}/postgresql/dolphinscheduler_dml.sql (99%)