You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ca...@apache.org on 2022/03/07 02:50:48 UTC
[dolphinscheduler] branch dev updated (9c162c8 -> b0fc6e7)
This is an automated email from the ASF dual-hosted git repository.
caishunfeng pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git.
from 9c162c8 [Fix][UI Next][V1.0.0-Alpha] Fix the regularly manage multilingual switching issues. (#8718)
add b0fc6e7 [Feature-5752][server]Add blocking task (#6272)
No new revisions were added by this update.
Summary of changes:
.../apache/dolphinscheduler/common/Constants.java | 2 +
...qoopQueryType.java => BlockingOpportunity.java} | 16 +-
.../common/enums/ExecutionStatus.java | 17 +-
.../common/enums/StateEventType.java | 4 +-
.../dolphinscheduler/common/enums/TaskType.java | 2 +
.../dolphinscheduler/common/model/TaskNode.java | 4 +
.../BlockingParameters.java} | 33 +--
.../common/utils/TaskParametersUtils.java | 3 +
.../dao/entity/ProcessInstance.java | 16 ++
.../dolphinscheduler/dao/entity/TaskInstance.java | 5 +
.../dolphinscheduler/dao/utils/DagHelper.java | 19 ++
.../master/runner/StateWheelExecuteThread.java | 3 -
.../master/runner/WorkflowExecuteThread.java | 125 ++++++++--
.../master/runner/task/BaseTaskProcessor.java | 1 +
...skProcessor.java => BlockingTaskProcessor.java} | 159 ++++++------
.../server/master/BlockingTaskTest.java | 270 +++++++++++++++++++++
.../server/master/WorkflowExecuteThreadTest.java | 2 +-
.../service/alert/ProcessAlertManager.java | 35 +++
.../service/alert/ProcessAlertManagerTest.java | 22 ++
19 files changed, 605 insertions(+), 133 deletions(-)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/{SqoopQueryType.java => BlockingOpportunity.java} (79%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/{dependent/DependentParameters.java => blocking/BlockingParameters.java} (58%)
copy dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/{ConditionTaskProcessor.java => BlockingTaskProcessor.java} (67%)
create mode 100644 dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/BlockingTaskTest.java