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