This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a change to branch dev-master-refactor
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git.
from 1887bde [NEW FEATURE][FIX-4385] compensation task add the ability to
configure parallelism (#5912)
add 0442326 [Improvement][dao]When I search for the keyword description,
the web UI shows empty (#5952)
add 4b892f7 fix the readme typing issue (#5998)
add 0206a0e Fix unchecked type conversions
add db6db88 Use indentation level reported by checkstyle
add ae386dd Merge pull request #6003 from
lyxell/fix-unchecked-type-conversions
add cfb03ce Reorganize CI workflows to fasten the wasted time and
resources (#6011)
add bf90106 Add standalone server module to make it easier to develop
(#6022)
add c37f148 Task node of SWITCH (#5939)
add 2e1768a [Feature-#5273][server-master] Task node of SWITCH (#5922)
add 42b912a remove description of bonecp (#6030)
add 75f15df [Improvement][Api Module]split alert group list-paging
interface (#5941)
add 7b85793 [FIX-#6007]Wrong complement date (#6026)
add 67dde65 [Improvement-6024][dist] Remove useless packaging commands
(#6029)
add 2fa3b41 [FIX-5908][MasterServer] When executing an compensation task,
the execution thread would have a NPE (#5909)
add 04720b3 Add `.asf.yaml` to easily set the GitHub metadata (#6035)
add 839d605 fix dead server cannot stop (#6046)
add 0373320 Enhancement Translation (#6042)
add 301a7b6 fix bug #6053 zh_CN.js is lost
add e0eea99 Merge pull request #6054 from lenboo/dev-zhCN
add e866d1b [Fix-6038][ui] width of "SQL Statement" in Dag FormLineModal
will be shrunk if sql line is too long (#6040)
add ca93b8a [Improvement] Fix inefficient map iterator (#6004)
add a06badb Enhance `StandaloneServer` so that we don't need to update
the version number manually (#6074)
add 0975bef Remove invalid character in `.asf.yaml` (#6075)
add b49f5b0 Remove invalid character `\n` in `.asf.yaml` (#6077)
new 3305587 Merge remote-tracking branch 'upstream/dev' into
dev-master-refactor
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 47 +
.github/actions/reviewdog-setup | 1 +
.github/actions/sanity-check/action.yml | 53 ++
.github/workflows/{ci_backend.yml => backend.yml} | 38 +-
.github/workflows/{ci_e2e.yml => e2e.yml} | 22 +-
.../workflows/{ci_frontend.yml => frontend.yml} | 31 +-
.github/workflows/{ci_ut.yml => unit-test.yml} | 99 +--
.gitmodules | 3 +
.licenserc.yaml | 5 +
README.md | 4 +-
README_zh_CN.md | 2 +-
docker/build/hooks/build | 4 +-
.../dolphinscheduler-alert-email/pom.xml | 13 +-
.../api/controller/AlertGroupController.java | 23 +
.../apache/dolphinscheduler/api/enums/Status.java | 1 +
.../api/service/AlertGroupService.java | 8 +
.../api/service/impl/AlertGroupServiceImpl.java | 41 +-
.../dolphinscheduler/api/utils/CheckUtils.java | 45 +-
.../api/controller/AlertGroupControllerTest.java | 38 +-
.../api/service/AlertGroupServiceTest.java | 28 +-
.../apache/dolphinscheduler/common/Constants.java | 1 +
.../dolphinscheduler/common/enums/DbType.java | 66 +-
.../dolphinscheduler/common/enums/TaskType.java | 4 +-
.../apache/dolphinscheduler/common/graph/DAG.java | 12 +-
.../dolphinscheduler/common/model/TaskNode.java | 19 +-
.../common/task/AbstractParameters.java | 3 +-
.../common/task/sql/SqlParameters.java | 6 +-
.../SwitchParameters.java} | 66 +-
.../common/task/switchtask/SwitchResultVo.java | 42 +-
.../common/utils/PropertyUtils.java | 18 +-
.../common/utils/TaskParametersUtils.java | 3 +
.../dao/datasource/SpringConnectionFactory.java | 1 +
.../dolphinscheduler/dao/entity/TaskInstance.java | 25 +
.../dao/mapper/AlertGroupMapper.java | 10 +
.../dolphinscheduler/dao/utils/DagHelper.java | 50 +-
.../dolphinscheduler/dao/vo/AlertGroupVo.java | 32 +-
.../dao/mapper/AlertGroupMapper.xml | 11 +-
.../dao/mapper/ProcessDefinitionMapper.xml | 4 +-
.../dolphinscheduler/dao/mapper/ProjectMapper.xml | 4 +-
.../dao/mapper/WorkFlowLineageMapper.xml | 3 +-
.../dolphinscheduler/dao/utils/DagHelperTest.java | 99 ++-
.../utils/ResourceProcessDefinitionUtilsTest.java | 2 +-
dolphinscheduler-dist/pom.xml | 7 +-
dolphinscheduler-dist/release-docs/LICENSE | 3 +-
.../src/main/assembly/dolphinscheduler-bin.xml | 9 -
.../registry/zookeeper/ZookeeperRegistry.java | 11 +-
.../server/entity/TaskExecutionContext.java | 14 +
.../dispatch/executor/NettyExecutorManager.java | 2 +-
.../master/runner/MasterBaseTaskExecThread.java | 15 +-
.../server/master/runner/MasterExecThread.java | 19 +-
.../server/master/runner/SwitchTaskExecThread.java | 180 ++++
.../utils/{ArgsUtils.java => SwitchTaskUtils.java} | 20 +-
.../server/worker/WorkerServer.java | 1 +
.../worker/runner/RetryReportTaskStatusThread.java | 1 +
.../server/worker/runner/TaskExecuteThread.java | 23 +-
.../server/worker/runner/WorkerManagerThread.java | 1 +
.../server/worker/task/datax/DataxTask.java | 8 +
.../server/worker/task/flink/FlinkTask.java | 15 +-
.../server/worker/task/http/HttpTask.java | 8 +
.../server/worker/task/mr/MapReduceTask.java | 21 +-
.../server/worker/task/python/PythonTask.java | 15 +-
.../server/worker/task/shell/ShellTask.java | 27 +-
.../server/worker/task/spark/SparkTask.java | 15 +-
.../server/worker/task/sql/SqlTask.java | 22 +-
.../server/worker/task/sqoop/SqoopTask.java | 11 +-
.../server/master/MasterExecThreadTest.java | 6 +-
...SubProcessTaskTest.java => SwitchTaskTest.java} | 144 ++--
.../server/worker/task/http/HttpTaskTest.java | 4 +-
.../service/process/ProcessService.java | 1 +
.../service/process/ProcessServiceTest.java | 14 +-
.../pom.xml | 35 +-
.../dolphinscheduler/server/StandaloneServer.java | 92 ++
.../src/js/conf/home/pages/dag/_source/config.js | 4 +
.../src/js/conf/home/pages/dag/_source/dag.scss | 3 +
.../src/js/conf/home/pages/dag/_source/dag.vue | 4 +-
.../pages/dag/_source/formModel/formLineModel.vue | 2 +-
.../pages/dag/_source/formModel/formModel.scss | 2 +
.../home/pages/dag/_source/formModel/formModel.vue | 19 +-
.../pages/dag/_source/formModel/tasks/switch.vue | 223 +++++
.../js/conf/home/pages/dag/img/toolbar_SWITCH.png | Bin 0 -> 2987 bytes
.../pages/list/_source/createDataSource.vue | 4 +-
.../pages/definition/pages/list/_source/start.vue | 2 +-
.../pages/definition/pages/list/_source/timing.vue | 2 +-
.../resource/pages/file/pages/create/index.vue | 2 +-
.../pages/file/pages/createFolder/index.vue | 2 +-
.../pages/file/pages/createUdfFolder/index.vue | 2 +-
.../pages/resource/pages/file/pages/edit/index.vue | 2 +-
.../resource/pages/file/pages/subFile/index.vue | 2 +-
.../pages/file/pages/subFileFolder/index.vue | 2 +-
.../pages/udf/pages/createUdfFolder/index.vue | 2 +-
.../pages/udf/pages/subUdfFolder/index.vue | 2 +-
.../pages/user/pages/password/_source/info.vue | 2 +-
dolphinscheduler-ui/src/js/conf/login/App.vue | 2 +-
.../js/module/components/fileUpdate/udfUpdate.vue | 2 +-
.../src/js/module/components/popup/popover.vue | 2 +-
.../src/js/module/components/popup/popup.vue | 2 +-
.../src/js/module/i18n/locale/en_US.js | 4 +-
.../src/js/module/i18n/locale/zh_CN.js | 4 +-
install.sh | 104 ---
pom.xml | 19 +-
script/dolphinscheduler-daemon.sh | 6 +-
sql/dolphinscheduler_h2.sql | 943 +++++++++++++++++++++
style/checkstyle-suppressions.xml | 24 -
style/checkstyle.xml | 7 +-
tools/dependencies/known-dependencies.txt | 1 +
105 files changed, 2488 insertions(+), 646 deletions(-)
create mode 100644 .asf.yaml
create mode 160000 .github/actions/reviewdog-setup
create mode 100644 .github/actions/sanity-check/action.yml
rename .github/workflows/{ci_backend.yml => backend.yml} (63%)
rename .github/workflows/{ci_e2e.yml => e2e.yml} (89%)
rename .github/workflows/{ci_frontend.yml => frontend.yml} (67%)
rename .github/workflows/{ci_ut.yml => unit-test.yml} (52%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/{conditions/ConditionsParameters.java
=> switchtask/SwitchParameters.java} (58%)
copy
dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/ResourceProcessDefinitionUtilsTest.java
=>
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/task/switchtask/SwitchResultVo.java
(54%)
copy
dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/register/RegistryFactory.java
=>
dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/vo/AlertGroupVo.java
(65%)
create mode 100644
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/SwitchTaskExecThread.java
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/{ArgsUtils.java
=> SwitchTaskUtils.java} (63%)
copy
dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/{SubProcessTaskTest.java
=> SwitchTaskTest.java} (57%)
copy {dolphinscheduler-alert-plugin =>
dolphinscheduler-standalone-server}/pom.xml (67%)
create mode 100644
dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/server/StandaloneServer.java
create mode 100644
dolphinscheduler-ui/src/js/conf/home/pages/dag/_source/formModel/tasks/switch.vue
create mode 100644
dolphinscheduler-ui/src/js/conf/home/pages/dag/img/toolbar_SWITCH.png
mode change 100755 => 100644
dolphinscheduler-ui/src/js/module/i18n/locale/zh_CN.js
delete mode 100755 install.sh
create mode 100644 sql/dolphinscheduler_h2.sql
delete mode 100644 style/checkstyle-suppressions.xml