You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by gi...@apache.org on 2022/07/06 06:25:01 UTC
[dolphinscheduler] branch dependabot/maven/dolphinscheduler-api-test/com.fasterxml.jackson.core-jackson-databind-2.13.2.1 updated (0cb251ae04 -> 50fefdaae9)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/dolphinscheduler-api-test/com.fasterxml.jackson.core-jackson-databind-2.13.2.1
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
discard 0cb251ae04 Bump jackson-databind in /dolphinscheduler-api-test
add eecc49e70c add codeowner (#10457)
add d16e0ddb2f [Bug-10394] [Update Possword] Change password shows error (#10437)
add 720a10a21e add_some_code_owners (#10462)
add f512e3c31f [fix][python] Correct variable type of SQL type (#10464)
add d1cae6025b fix rename form not init bug in file manange (#10471)
add 7aa9fa4965 [imporve] Add index to table t_ds_relation_process_instance (#10461)
add f3c647d45e [Improvement][Api] Interface and entity optimization to improve code scalability (#10466). (#10468)
add ad2646ff1f Fix TaskProcessorFactory#getTaskProcessor get common processor is not thread safe (#10479)
add 062146eecd [Fix] Fix the JSONUtils tool class time zone problem #10282 (#10284)
add 0dd6f4008e [fix][master]: fix condition npe (#10478)
add 6515c66208 [Improve] Add LDAP user not exsitst action config (#10451)
add f1a9c0d8e9 [Improvement][Api] Interface and entity optimization to improve code scalability. (#10483)
add 0bdfa0cff9 Fix PeerTaskInstancePriorityQueue cannot contains method use taskInstanceId to check (#10491)
add 00f86da1da Open checkstyle, change checkstyle severity from info to warning (#10492)
add b8d5e78994 [Doc] Add how to set the alarm mailbox in faq (#10401)
add 2c227ab384 [Feature-10363][server] S3 Resource center supports bucket customization (#10433)
add 4be3b877c3 [feature][task] Enable zeppelin schedule a whole zeppelin note (#10434)
add 704e633659 [Doc] Add api test doc (#10499)
add 79ce5d78cd Modify obsolete swagger parameters in AuditLogController (#10494)
add 64cee03fed [Feature] Enable users to switch and install conda env in jupyter task (#10337)
add 6e4b2e6992 [Fix]Recovery Traffic Control Config (#10505)
add 117f78ec4b [Fix-10413] Fix Master startup failure the server still hang (#10500)
add 36e20cdfc8 [Feature][Task Plugin] Add DVC task plugin for MLops scenario (#10372) (#10407)
add b100f6c489 Remove the schedule thread in LowerWeightHostManager (#10310)
add cc06eaaf54 [Improvement][Metrics] Apply micrometer naming convention to metrics (#10477)
add 4a3dfae006 [FIX] Could not find or load main class org.apache.zookeeper.ZooKeeperMain (#10535)
add d7cf09afd5 Revert "[Improvement][Api] Interface and entity optimization to improve code scalability. (#10483)" (#10534)
add bf077cb38f change import method access to protected (#10536)
add cefcb6d556 [Fix-10522] [API] Fix get executable time null pointer exception (#10523)
add 6396fa9965 add codeowner (#10537)
add f46faa02c3 [Fix-10452] Serial wait for policy recovery (#10453)
add 559f387e66 [Fix-10274]Close InitialLDAPContext In LDAP (#10532)
add 20348578a2 [Feature] [Permission]Data permission module added and Query class api remove verification. (#10504)
add 9345c16f3f [Improve]Remove the code logger.isDebugEnabled() #5918 (#10542)
add 198e00db58 fix: Current node settings number of failed retries may not be negative (#10530)
add 0aba68f335 [Improvement][Metrics] Update some metrics names in grafana-demo dashboards (#10432) (#10552)
add bc4ceda4cf TaskGroup remove query func permission check. (#10557)
add 3918140e7e [fix][doc] Add DVC task plugin doc link (#10529)
add b2879c0e05 [Fix] fix the HttpUtilsTest' test case , it is always time out. (#10294)
add 388b214aca [fix] Change K8s postgresql password key name (#10545)
add db595b3eff Optimize master log, use MDC to inject workflow instance id and task instance id in log (#10516)
add 1b1a567fec [doc] Correct the complement add docs (#10521)
add 773ebc9e52 fix 10513 (#10564)
add 08e2c245a8 Update SparkRuntimeEnvironment.java (#10549)
add 0f38217b12 fix_10514 (#10568)
add 7a292cfccf fix standalone start error (#10577)
add 393cb648f9 fix dependent task re-run params error (#10580)
add 7970573365 [python] Support using full-name definitions for resources (#10551)
add 1111371c9a add datasource health check to the healthcheck endpoint (#10588)
add 15a86071d1 [feat] ui build no inherit from maven proxy (#10590)
add 0b377f72b1 [Fix-10400]Fix K8s deployment bitnami version error (#10567)
add b21e211d2c [doc] Add docs about complement dependent mode (#10587)
add 397e51fa63 dependent node log output optimization and fix checkstyle (#10593)
add 33cc68ed4a [doc] Add doc about how to use healthcheck endpoints (#10592)
add b2df357814 [doc] Add run the task alone doc. (#10581)
add 16144a8858 [docs] Add links to metrics docs (#10583)
add 628c8ab2a1 [Improvement][Master] batch remove TaskInstaceId and workflowInstanceId (#10620)
add 719a9d4532 [Improvement][Worker] fixed naming of rpc package (#10614)
add dafed572d1 [Fix][dolphinscheduler-spi] json parse support LocalDateTime (#10440)
add b8de9ee752 [Fix-10539] [Bug] [UI] Copy task a to B, change the user-defined para… (#10611)
add cd51a22940 [doc] Correct installPath when using related path (#10597)
add a6fc70cdd1 [Fix][UI] Fix bytesToSize function calculation error. (#10627)
add a14b96b091 [doc] Modify Shell task file (#10634)
add 56d3db0306 [fix-10596] Workflow relationship cannot be displayed normally (#10625)
add 1f46078ab8 [doc] Change subprocess dependent (#10637)
add bbc1e052ab [ci] mergable do not handle label (#10638)
add d021da4dfb [fix-10632][ui] fix the workflow name with underline cannot be displayed correctly error. (#10636)
add b5184138fa [Feature] Time function analysis extension. (#10624)
add cd62de968d Add JDK11 on unit-test (#10364)
add 66624c5c86 [Bug] [Master] Worker failover will cause task cannot be failover (#10631)
add 35b25da863 Validate master/worker config (#10649)
add 5ebd982e92 [Bug] [Api] The copied workflow create time and update time is still copied from the original workflow
add e0b0f986f7 [Fix-10641] [Common] Fix the hdfs NPE (#10642)
add 7e7df1d8ff [Bug] [Task] SQL task no exception stack trace in task log (#10656)
add 75581b7543 [Improvement]Delete the getSession in the Registry interface (#10633)
add 1cdbbc1ba5 [doc] Modified parameter doc files. (#10659)
add 3fbfa27f13 [doc] Replace the dag screenshot of the README. (#10662)
add cf7776fb8d [Refactor][UI] Refactor yarn queue manage using NSpace component. (#10680)
add e6efac6223 [Refactor][UI] Refactor token manage using NSpace component. (#10681)
add a90e5746fc [Refactor][UI] Refactor k8s namespace manage using NSpace component. (#10682)
add 5855274b26 [Fix-10652] fix docker-compose.yml (#10653)
add 247ca4ae8a [Improvement-10617] Add comment in slot check (#10618)
add c2f1886306 [doc] Update metadata and design doc (#10600)
add 77fea14461 [Fix][UI] Fix bug where the home page displays no data. (#10697)
add b6a3075a42 [Improvement] heartbeat info improvement (#10699)
add 1b86394d3c Optimize sql script use insert ignore (#10700)
add fcf4110ed8 resource modules query fix. (#10687)
add a45fc5b032 [doc] Add doc for pre-sql and post-sql (#10685)
add 8f621ff98b [Optimization] Calculate global parameter and local parameter at master. (#10704)
add 7898f41dc0 [doc] Change datasource doc (#10660)
add 65ebdbef98 [doc] Change tasks doc (#10639)
add c732db29ee [Refactor][UI] Refactor environment manage using NSpace component. (#10702)
add 491d5001fc [Refactor][UI] Refactor cluster manage using NSpace component. (#10701)
add 4bbf3c8ea1 fix (#10678)
add 4a3c3e7797 [feature][task-flink] Support Flink application mode (#9577)
add 48d0e7f389 fix bug where project overview page display no data (#10720)
add 0cdae777ab [doc] Modified alert doc files (#10714)
add fb90a0e558 [doc] Modify quick start. (#10712)
add fb8d0c858b Merging general settings to faq (#10716)
add d0f73d3d7c [Refactor][UI] Refactor worker group manage using NSpace component. (#10735)
add 4ac33496e5 [Docs] Replace the dag screenshot of the README. (#10741)
add 4f0a02eb43 [chore] update by release version (#10742)
add 423cc5b9be [doc] Modified project doc. (#10711)
add 6cf9d088ff [doc] Change tasks docs (#10751)
add 7c740da242 Add improvement template (#10764)
add 7aad6a6515 [doc] Unify data source switching of the docs during installation (#10688)
add f8650b7b7c [Bug] [Api-Service] Workflow and subworkflow instance does not change after clicking rerun。 (#10727)
add 35a10d092f [Fix-10666] Workflow submit failed will still in memory and never retry (#10667)
add 182b9c9b26 [Feature][Master] Failover workflow instance base on priority (#10754)
add 5b0347e8da [Task] Add Dinky task to better support the development and execution of FlinkSQL (#10640)
add 7d79a2165e [Optimization]Optimize some details of MLFlow task plugin #10740 (#10739)
add b1ccdb4b39 Fix language not matched (#10775)
add 91283e59cf [Bug][Script] Remove deprecated arg in remove-zk-node.sh (#10789)
add d2fe16d252 [Optimization] Config module resource relation fix. (#10718)
add 43d7cc8a98 [Improvement] [Alert Server] Add default datasource url in alert server application.yaml for consistency (#10790)
add b4eee7edb6 [python] Correct some docs for python api (#10772)
add bd1be6cf36 [Task] Added Apache SeaTunnel 2.x task node (#10480)
add 2a519ea900 [doc] Replace the dag screenshot of the README. (#10798)
add 91b59dee54 [doc] Modified dq, monitor, security, resources (#10715)
add a1aff5156e [Fix][UI] Fix the environment name display back error. (#10797)
add fa1458b3e0 [doc] Modify features, hw, intro and homepage docs. (#10713)
add 1e0ab00c69 [Refactor][UI] Refactor alarm instance manage using NSpace component. (#10799)
add c5a340be60 [Refactor][UI] Refactor alarm group manage using NSpace component. (#10803)
add 2d8b4932b3 [doc] Correct custom jdbc driver for K8s Doc (#10768)
add 1485c6fba2 Add doc issue template (#10804)
add b7fbf6c4ad [API] Do not specify rollback for ensure in case of any exception or error. (#10793)
add 515b5e3ef6 [API-Test] [Checkstyle] Reformat api-test code and enable checkstyle (#10805)
add 50fefdaae9 Bump jackson-databind in /dolphinscheduler-api-test
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0cb251ae04)
\
N -- N -- N refs/heads/dependabot/maven/dolphinscheduler-api-test/com.fasterxml.jackson.core-jackson-databind-2.13.2.1 (50fefdaae9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 13 +-
.github/ISSUE_TEMPLATE/bug-report.yml | 2 +-
.github/ISSUE_TEMPLATE/document.yml | 73 ++
.github/ISSUE_TEMPLATE/improvement-report.yml | 68 ++
.github/mergeable.yml | 25 +-
.github/workflows/api-test.yml | 3 +-
.github/workflows/backend.yml | 16 +-
.github/workflows/e2e.yml | 2 +-
.github/workflows/publish-docker.yaml | 2 +-
.github/workflows/py-ci.yml | 2 +-
.github/workflows/unit-test.yml | 9 +-
deploy/docker/docker-compose.yml | 1 +
deploy/docker/docker-stack.yml | 1 +
deploy/kubernetes/dolphinscheduler/Chart.yaml | 14 +-
.../templates/deployment-dolphinscheduler-api.yaml | 2 +
.../templates/svc-dolphinscheduler-api.yaml | 7 +
docs/configs/docsdev.js | 88 ++-
docs/configs/site.js | 4 +-
docs/docs/en/about/features.md | 19 +
docs/docs/en/about/hardware.md | 6 +-
docs/docs/en/about/introduction.md | 18 +-
docs/docs/en/architecture/configuration.md | 53 +-
docs/docs/en/architecture/design.md | 144 ++--
docs/docs/en/architecture/metadata.md | 189 +----
docs/docs/en/development/api-test.md | 94 +++
docs/docs/en/faq.md | 5 +-
.../docs/en/guide/alert/alert_plugin_user_guide.md | 16 +-
docs/docs/en/guide/alert/dingtalk.md | 34 +-
docs/docs/en/guide/alert/email.md | 10 +
docs/docs/en/guide/alert/enterprise-webexteams.md | 33 +-
docs/docs/en/guide/alert/enterprise-wechat.md | 4 +-
docs/docs/en/guide/alert/http.md | 21 +-
docs/docs/en/guide/alert/script.md | 17 +-
docs/docs/en/guide/alert/telegram.md | 41 +-
docs/docs/en/guide/data-quality.md | 497 ++++++------
docs/docs/en/guide/datasource/clickhouse.md | 21 +
docs/docs/en/guide/datasource/db2.md | 21 +
docs/docs/en/guide/datasource/hive.md | 22 +-
docs/docs/en/guide/datasource/introduction.md | 24 -
docs/docs/en/guide/datasource/mysql.md | 24 +-
docs/docs/en/guide/datasource/oracle.md | 20 +
docs/docs/en/guide/datasource/postgresql.md | 22 +-
docs/docs/en/guide/datasource/presto.md | 22 +
docs/docs/en/guide/datasource/redshift.md | 20 +
docs/docs/en/guide/datasource/spark.md | 22 +-
docs/docs/en/guide/datasource/sql-server.md | 22 +
docs/docs/en/guide/healthcheck.md | 41 +
docs/docs/en/guide/homepage.md | 2 +-
docs/docs/en/guide/howto/datasource-setting.md | 94 +++
docs/docs/en/guide/howto/general-setting.md | 2 -
docs/docs/en/guide/installation/kubernetes.md | 9 +-
docs/docs/en/guide/installation/pseudo-cluster.md | 50 +-
docs/docs/en/guide/installation/standalone.md | 16 +-
docs/docs/en/guide/metrics/metrics.md | 295 +++----
docs/docs/en/guide/monitor.md | 12 +-
docs/docs/en/guide/parameter/built-in.md | 58 +-
docs/docs/en/guide/parameter/context.md | 2 +-
docs/docs/en/guide/parameter/global.md | 2 +
docs/docs/en/guide/parameter/local.md | 24 +-
docs/docs/en/guide/parameter/priority.md | 10 +-
docs/docs/en/guide/project/project-list.md | 21 +-
docs/docs/en/guide/project/task-instance.md | 4 +-
docs/docs/en/guide/project/workflow-definition.md | 79 +-
docs/docs/en/guide/project/workflow-instance.md | 10 +-
docs/docs/en/guide/project/workflow-relation.md | 3 +
docs/docs/en/guide/resource/configuration.md | 77 +-
docs/docs/en/guide/resource/intro.md | 5 +
docs/docs/en/guide/resource/task-group.md | 14 +-
docs/docs/en/guide/resource/udf-manage.md | 16 +-
docs/docs/en/guide/security.md | 18 +-
docs/docs/en/guide/start/quick-start.md | 8 +-
docs/docs/en/guide/task/conditions.md | 36 +-
docs/docs/en/guide/task/datax.md | 58 +-
docs/docs/en/guide/task/dependent.md | 29 +-
docs/docs/en/guide/task/dinky.md | 40 +
docs/docs/en/guide/task/dvc.md | 125 +++
docs/docs/en/guide/task/emr.md | 29 +-
docs/docs/en/guide/task/flink.md | 66 +-
docs/docs/en/guide/task/http.md | 43 +-
docs/docs/en/guide/task/jupyter.md | 83 +-
docs/docs/en/guide/task/kubernetes.md | 44 +-
docs/docs/en/guide/task/map-reduce.md | 74 +-
docs/docs/en/guide/task/mlflow.md | 128 ++-
docs/docs/en/guide/task/openmldb.md | 69 +-
docs/docs/en/guide/task/pigeon.md | 32 +-
docs/docs/en/guide/task/python.md | 37 +-
docs/docs/en/guide/task/seatunnel.md | 82 ++
docs/docs/en/guide/task/shell.md | 53 +-
docs/docs/en/guide/task/spark.md | 65 +-
docs/docs/en/guide/task/sql.md | 41 +-
docs/docs/en/guide/task/stored-procedure.md | 21 +-
docs/docs/en/guide/task/sub-process.md | 25 +-
docs/docs/en/guide/task/switch.md | 47 +-
docs/docs/en/guide/task/zeppelin.md | 32 +-
docs/docs/en/history-versions.md | 4 +-
docs/docs/zh/about/features.md | 19 +
docs/docs/zh/about/introduction.md | 14 +-
docs/docs/zh/architecture/configuration.md | 54 +-
docs/docs/zh/architecture/design.md | 195 ++---
docs/docs/zh/architecture/metadata.md | 194 +----
docs/docs/zh/development/api-test.md | 93 +++
docs/docs/zh/faq.md | 5 +-
docs/docs/zh/guide/alert/email.md | 6 +
docs/docs/zh/guide/datasource/introduction.md | 21 -
docs/docs/zh/guide/datasource/mysql.md | 2 +-
docs/docs/zh/guide/healthcheck.md | 41 +
docs/docs/zh/guide/homepage.md | 2 +-
docs/docs/zh/guide/howto/datasource-setting.md | 92 +++
docs/docs/zh/guide/installation/kubernetes.md | 17 +-
docs/docs/zh/guide/installation/pseudo-cluster.md | 50 +-
docs/docs/zh/guide/installation/standalone.md | 15 +-
docs/docs/zh/guide/metrics/metrics.md | 172 +++++
docs/docs/zh/guide/project/workflow-definition.md | 25 +-
docs/docs/zh/guide/resource/configuration.md | 31 +-
docs/docs/zh/guide/resource/intro.md | 4 +
docs/docs/zh/guide/task/dinky.md | 40 +
docs/docs/zh/guide/task/dvc.md | 110 +++
docs/docs/zh/guide/task/flink.md | 2 +-
docs/docs/zh/guide/task/jupyter.md | 47 +-
docs/docs/zh/guide/task/seatunnel.md | 82 ++
docs/docs/zh/guide/task/sql.md | 14 +-
docs/docs/zh/guide/task/zeppelin.md | 2 +-
docs/docs/zh/history-versions.md | 4 +-
docs/img/alert/email-alter-setup1-en.png | Bin 0 -> 27742 bytes
docs/img/alert/email-alter-setup2-en.png | Bin 0 -> 47734 bytes
docs/img/alert/email-alter-setup3-en.png | Bin 0 -> 43983 bytes
docs/img/distributed_lock_procss.png | Bin 26481 -> 0 bytes
docs/img/introduction_ui.png | Bin 0 -> 159241 bytes
docs/img/metadata-erd/command.png | Bin 56471 -> 0 bytes
docs/img/metadata-erd/process-task.png | Bin 291362 -> 0 bytes
docs/img/metadata-erd/process_definition.png | Bin 0 -> 150909 bytes
.../project_tenant_process_definition_schedule.png | Bin 0 -> 65439 bytes
docs/img/new_ui/dev/datasource/ClickHouse.png | Bin 0 -> 84070 bytes
docs/img/new_ui/dev/datasource/DB2.png | Bin 0 -> 83693 bytes
docs/img/new_ui/dev/datasource/oracle.png | Bin 0 -> 83589 bytes
docs/img/new_ui/dev/datasource/presto.png | Bin 0 -> 83880 bytes
docs/img/new_ui/dev/datasource/redshift.png | Bin 0 -> 83630 bytes
docs/img/new_ui/dev/datasource/sql_server.png | Bin 0 -> 85036 bytes
docs/img/new_ui/dev/project/work-relation.png | Bin 0 -> 64892 bytes
.../dev/project/workflow-task-run-config.png | Bin 0 -> 84218 bytes
docs/img/new_ui/dev/project/workflow-task-run.png | Bin 0 -> 18730 bytes
.../new_ui/dev/project/workflow_date_manual.png | Bin 0 -> 25415 bytes
docs/img/tasks/demo/dinky.png | Bin 0 -> 146042 bytes
docs/img/tasks/demo/dinky_task_id.png | Bin 0 -> 170795 bytes
docs/img/tasks/demo/dvc_download.png | Bin 0 -> 24920 bytes
docs/img/tasks/demo/dvc_env_config.png | Bin 0 -> 122301 bytes
docs/img/tasks/demo/dvc_env_name.png | Bin 0 -> 49877 bytes
docs/img/tasks/demo/dvc_init.png | Bin 0 -> 16107 bytes
docs/img/tasks/demo/dvc_upload.png | Bin 0 -> 28869 bytes
docs/img/tasks/demo/pre_post_sql.png | Bin 0 -> 86619 bytes
docs/img/tasks/demo/seatunnel_task01.png | Bin 0 -> 158509 bytes
docs/img/tasks/demo/seatunnel_task02.png | Bin 0 -> 207915 bytes
docs/img/tasks/icons/dinky.png | Bin 0 -> 6447 bytes
docs/img/tasks/icons/dvc.png | Bin 0 -> 7649 bytes
.../img/tasks/icons}/seatunnel.png | Bin
.../apache/dolphinscheduler/alert/AlertServer.java | 23 +-
.../src/main/resources/application.yaml | 12 +
.../src/main/resources/logback-spring.xml | 2 +
dolphinscheduler-api-test/README.md | 4 +-
.../api.test/cases/TenantAPITest.java | 3 +-
.../entity/TenantListPagingResponseData.java | 4 +-
.../entity/TenantListPagingResponseTotalList.java | 4 +-
.../dolphinscheduler/api.test/pages/LoginPage.java | 1 -
.../api.test/pages/security/TenantPage.java | 1 -
.../dolphinscheduler/api.test/utils/JSONUtils.java | 50 +-
.../api.test/utils/RequestClient.java | 38 +-
.../resources/docker/basic/docker-compose.yaml | 28 +-
.../datasource-clickhouse/docker-compose.yaml | 2 +-
.../docker/datasource-hive/docker-compose.yaml | 2 +-
.../datasource-postgresql/docker-compose.yaml | 2 +-
.../resources/docker/file-manage/common.properties | 25 +-
.../docker/file-manage/docker-compose.yaml | 2 +-
.../dolphinscheduler/api/test/core/Constants.java | 3 -
.../api/test/core/DolphinSchedulerExtension.java | 25 +-
dolphinscheduler-api-test/pom.xml | 33 +
.../api/configuration/AppConfiguration.java | 2 +-
.../api/configuration/TrafficConfiguration.java | 62 +-
.../constants/ApiFuncIdentificationConstant.java | 2 -
.../api/controller/AlertGroupController.java | 2 +-
.../api/controller/AuditLogController.java | 8 +-
.../api/controller/EnvironmentController.java | 2 +-
.../controller/ProcessDefinitionController.java | 78 +-
.../api/controller/ProcessInstanceController.java | 49 +-
.../api/controller/WorkerGroupController.java | 2 +-
.../api/dto/ProcessDefinitionDto.java | 18 +-
.../api/dto/ProcessInstanceDto.java | 18 +-
.../apache/dolphinscheduler/api/enums/Status.java | 1 +
.../api/interceptor/RateLimitInterceptor.java | 6 +-
.../ResourcePermissionCheckServiceImpl.java | 197 ++---
.../dolphinscheduler/api/python/PythonGateway.java | 58 +-
.../api/security/LdapUserNotExistActionType.java | 38 +-
.../api/security/impl/ldap/LdapAuthenticator.java | 2 +-
.../api/security/impl/ldap/LdapService.java | 41 +-
.../api/service/AlertGroupService.java | 3 +-
.../dolphinscheduler/api/service/BaseService.java | 6 +-
.../api/service/EnvironmentService.java | 3 +-
.../api/service/ProcessDefinitionService.java | 46 +-
.../api/service/ProcessInstanceService.java | 10 +-
.../api/service/WorkerGroupService.java | 3 +-
.../api/service/impl/AccessTokenServiceImpl.java | 15 +-
.../api/service/impl/AlertGroupServiceImpl.java | 26 +-
.../impl/AlertPluginInstanceServiceImpl.java | 5 -
.../api/service/impl/BaseServiceImpl.java | 21 +-
.../api/service/impl/ClusterServiceImpl.java | 6 +-
.../api/service/impl/DataAnalysisServiceImpl.java | 6 -
.../api/service/impl/DataSourceServiceImpl.java | 24 +-
.../service/impl/DqExecuteResultServiceImpl.java | 4 -
.../api/service/impl/DqRuleServiceImpl.java | 4 -
.../api/service/impl/EnvironmentServiceImpl.java | 18 +-
.../api/service/impl/ExecutorServiceImpl.java | 7 +-
.../api/service/impl/K8SNamespaceServiceImpl.java | 5 -
.../api/service/impl/MonitorServiceImpl.java | 16 -
.../service/impl/ProcessDefinitionServiceImpl.java | 220 ++++--
.../service/impl/ProcessInstanceServiceImpl.java | 67 +-
.../impl/ProcessTaskRelationServiceImpl.java | 10 +-
.../api/service/impl/ProjectServiceImpl.java | 8 +-
.../api/service/impl/QueueServiceImpl.java | 46 +-
.../api/service/impl/ResourcesServiceImpl.java | 54 +-
.../api/service/impl/SchedulerServiceImpl.java | 6 +-
.../api/service/impl/SessionServiceImpl.java | 2 +-
.../service/impl/TaskDefinitionServiceImpl.java | 12 +-
.../service/impl/TaskGroupQueueServiceImpl.java | 23 +-
.../api/service/impl/TaskGroupServiceImpl.java | 27 +-
.../api/service/impl/TenantServiceImpl.java | 25 +-
.../api/service/impl/UdfFuncServiceImpl.java | 3 +-
.../api/service/impl/UsersServiceImpl.java | 25 +-
.../service/impl/WorkFlowLineageServiceImpl.java | 13 +-
.../api/service/impl/WorkerGroupServiceImpl.java | 50 +-
.../dolphinscheduler/api/utils/CheckUtils.java | 14 +-
.../src/main/resources/application.yaml | 37 +-
.../src/main/resources/logback-spring.xml | 2 +
.../configuration/TrafficConfigurationTest.java | 6 +-
.../ProcessDefinitionControllerTest.java | 31 +-
.../controller/ProcessInstanceControllerTest.java | 20 +-
.../api/interceptor/RateLimitInterceptorTest.java | 8 +-
.../ResourcePermissionCheckServiceTest.java | 14 +-
.../api/python/PythonGatewayTest.java | 44 ++
.../api/security/SecurityConfigLDAPTest.java | 14 +
.../security/impl/ldap/LdapAuthenticatorTest.java | 26 +-
.../api/security/impl/ldap/LdapServiceTest.java | 7 +-
.../api/service/AccessTokenServiceTest.java | 9 +-
.../api/service/AlertGroupServiceTest.java | 16 +-
.../api/service/DataAnalysisServiceTest.java | 2 -
.../api/service/DataSourceServiceTest.java | 9 +
.../api/service/EnvironmentServiceTest.java | 11 +-
.../api/service/K8SNamespaceServiceTest.java | 2 -
.../api/service/MonitorServiceTest.java | 6 +-
.../api/service/ProcessDefinitionServiceTest.java | 60 +-
.../api/service/ProcessInstanceServiceTest.java | 43 +-
.../api/service/ProjectServiceTest.java | 11 +-
.../api/service/QueueServiceTest.java | 27 +-
.../api/service/ResourcesServiceTest.java | 18 +-
.../api/service/TaskGroupServiceTest.java | 2 +-
.../api/service/TenantServiceTest.java | 12 +-
.../api/service/WorkerGroupServiceTest.java | 14 +-
.../dolphinscheduler/api/utils/CheckUtilsTest.java | 3 +
dolphinscheduler-common/pom.xml | 7 +
.../apache/dolphinscheduler/common/Constants.java | 63 +-
.../dolphinscheduler/common/enums/StateEvent.java | 77 +-
.../common/storage/StorageOperate.java | 32 +-
.../thread/{Stopper.java => BaseDaemonThread.java} | 22 +-
.../dolphinscheduler/common/thread/Stopper.java | 34 +-
.../common/thread/ThreadUtils.java | 18 +-
.../dolphinscheduler/common/utils/FileUtils.java | 29 +-
.../dolphinscheduler/common/utils/HadoopUtils.java | 86 ++-
.../dolphinscheduler/common/utils/JSONUtils.java | 4 +
.../dolphinscheduler/common/utils/LoggerUtils.java | 34 +-
.../dolphinscheduler/common/utils/OSUtils.java | 21 +-
.../common/utils/ParameterUtils.java | 52 --
.../dolphinscheduler/common/utils/S3Utils.java | 204 +++--
.../utils/placeholder/TimePlaceholderUtils.java | 2 +-
.../src/main/resources/common.properties | 34 +-
.../common/utils/JSONUtilsTest.java | 31 +-
.../common/utils/LocalJettyHttpServer.java | 77 ++
.../common/utils/LocalServerHttpUtilsTest.java | 80 ++
.../common/utils/ParameterUtilsTest.java | 79 +-
.../dao/entity/ProcessInstance.java | 12 +-
.../dolphinscheduler/dao/mapper/QueueMapper.java | 2 +-
.../dao/mapper/TaskGroupMapper.java | 13 +-
.../dolphinscheduler/dao/mapper/TenantMapper.java | 8 +-
.../dolphinscheduler/dao/utils/DagHelper.java | 5 +
.../dao/mapper/AccessTokenMapper.xml | 5 +-
.../dolphinscheduler/dao/mapper/QueueMapper.xml | 6 +
.../dao/mapper/TaskGroupMapper.xml | 28 +-
.../dolphinscheduler/dao/mapper/TenantMapper.xml | 13 +
.../main/resources/sql/dolphinscheduler_mysql.sql | 856 +++++++++++----------
.../resources/sql/dolphinscheduler_postgresql.sql | 2 +
.../3.0.0_schema/mysql/dolphinscheduler_ddl.sql | 2 +
.../postgresql/dolphinscheduler_ddl.sql | 6 +
.../dao/mapper/QueueMapperTest.java | 7 +-
.../dao/mapper/TaskGroupMapperTest.java | 3 +-
.../dao/mapper/TenantMapperTest.java | 4 +-
.../quality/execution/SparkRuntimeEnvironment.java | 2 +-
.../datasource/api/utils/DataSourceUtils.java | 4 +-
.../datasource/api/utils/CommonUtilsTest.java | 47 +-
.../resources/docker/file-manage/common.properties | 15 +-
.../builder/TaskExecutionContextBuilder.java | 27 +
.../server/master/MasterServer.java | 25 +-
.../cache/ProcessInstanceExecCacheManager.java | 4 +-
.../impl/ProcessInstanceExecCacheManagerImpl.java | 7 +-
.../server/master/config/MasterConfig.java | 206 ++---
.../master/consumer/TaskPriorityQueueConsumer.java | 25 +-
.../server/master/dispatch/ExecutorDispatcher.java | 2 -
.../dispatch/host/LowerWeightHostManager.java | 136 ++--
.../server/master/exception/MasterException.java | 21 +-
.../server/master/metrics/MasterServerMetrics.java | 4 +-
.../master/metrics/ProcessInstanceMetrics.java | 63 +-
.../server/master/metrics/TaskMetrics.java | 28 +-
.../master/processor/StateEventProcessor.java | 12 +-
.../master/processor/TaskEventProcessor.java | 14 +-
.../processor/TaskExecuteResponseProcessor.java | 12 +-
.../processor/TaskKillResponseProcessor.java | 3 +-
.../master/processor/TaskRecallProcessor.java | 10 +-
.../processor/queue/StateEventResponseService.java | 31 +-
.../server/master/processor/queue/TaskEvent.java | 106 +--
.../master/processor/queue/TaskEventService.java | 17 +-
.../processor/queue/TaskExecuteRunnable.java | 3 +
.../processor/queue/TaskExecuteThreadPool.java | 22 +-
.../master/registry/MasterRegistryClient.java | 18 +-
.../server/master/registry/ServerNodeManager.java | 22 +
.../master/registry/WorkerInfoChangeListener.java | 28 +-
.../server/master/runner/EventExecuteService.java | 26 +-
.../master/runner/FailoverExecuteThread.java | 17 +-
.../master/runner/MasterSchedulerService.java | 212 +++--
.../master/runner/StateWheelExecuteThread.java | 259 ++++---
.../master/runner/WorkflowExecuteRunnable.java | 307 ++++----
.../master/runner/WorkflowExecuteThreadPool.java | 53 +-
.../server/master/runner/WorkflowSubmitStatue.java | 28 +-
.../master/runner/task/BaseTaskProcessor.java | 37 +-
.../master/runner/task/CommonTaskProcessor.java | 4 +-
.../master/runner/task/DependentTaskProcessor.java | 11 +-
.../master/runner/task/SubTaskProcessor.java | 6 +-
.../server/master/runner/task/TaskInstanceKey.java | 62 +-
.../master/runner/task/TaskProcessorFactory.java | 28 +-
.../server/master/service/FailoverService.java | 104 +--
.../src/main/resources/application.yaml | 21 +-
.../src/main/resources/logback-spring.xml | 6 +-
.../server/master/BlockingTaskTest.java | 5 +-
.../server/master/ConditionsTaskTest.java | 3 +-
.../server/master/DependentTaskTest.java | 3 +-
.../server/master/SubProcessTaskTest.java | 3 +-
.../server/master/SwitchTaskTest.java | 3 +-
.../ProcessInstanceExecCacheManagerImplTest.java | 2 +-
.../master/dispatch/ExecutionContextTestUtils.java | 3 +-
.../executor/NettyExecutorManagerTest.java | 2 +-
.../dispatch/host/RefreshResourceTaskTest.java | 47 --
.../WorkflowExecuteRunnableTest.java} | 23 +-
.../runner/task/TaskProcessorFactoryTest.java | 4 +-
.../server/master/service/FailoverServiceTest.java | 21 +-
.../dolphinscheduler/meter/MeterConfiguration.java | 4 -
.../resources/grafana/DolphinSchedulerMaster.json | 58 +-
.../resources/grafana/DolphinSchedulerWorker.json | 36 +-
.../pydolphinscheduler/DEVELOP.md | 4 +-
.../pydolphinscheduler/README.md | 6 +-
.../pydolphinscheduler/docs/source/conf.py | 1 +
.../pydolphinscheduler/docs/source/config.rst | 71 +-
.../docs/source/howto/remote-submit.rst | 6 +-
.../pydolphinscheduler/docs/source/start.rst | 49 +-
.../pydolphinscheduler/setup.py | 1 +
.../src/pydolphinscheduler/constants.py | 6 +
.../pydolphinscheduler/core/process_definition.py | 1 +
.../src/pydolphinscheduler/core/task.py | 26 +-
.../src/pydolphinscheduler/tasks/sql.py | 8 +-
.../pydolphinscheduler/tests/core/test_task.py | 39 +-
.../pydolphinscheduler/tests/tasks/test_sql.py | 4 +-
.../dolphinscheduler/registry/api/Registry.java | 2 -
.../plugin/registry/mysql/MysqlRegistry.java | 4 -
.../registry/zookeeper/ZookeeperRegistry.java | 5 -
dolphinscheduler-registry/pom.xml | 1 -
.../dolphinscheduler/remote/command/Command.java | 3 +
.../remote/command/TaskExecuteRequestCommand.java | 42 +-
.../processor/StateEventCallbackService.java | 8 +
.../remote/utils/ChannelUtils.java | 12 +-
.../apache/dolphinscheduler/remote/utils/Host.java | 2 +
.../scheduler/quartz/ProcessScheduleTask.java | 4 +-
.../scheduler/quartz/QuartzScheduler.java | 1 -
.../server/utils/ProcessUtils.java | 8 +-
.../service/alert/AlertClientService.java | 21 +-
.../dolphinscheduler/service/corn/CronUtils.java | 48 +-
.../service/expand/CuringGlobalParams.java | 228 ++++++
.../service/expand/CuringParamsService.java | 85 ++
.../TimePlaceholderResolverExpandService.java | 36 +-
.../TimePlaceholderResolverExpandServiceImpl.java | 33 +-
.../service/process/ProcessService.java | 16 +-
.../service/process/ProcessServiceImpl.java | 143 ++--
.../queue/PeerTaskInstancePriorityQueue.java | 53 +-
.../service/registry/RegistryClient.java | 4 -
.../service/task/TaskPluginManager.java | 5 +-
.../expand/CuringGlobalParamsServiceTest.java | 151 ++++
.../TimePlaceholderResolverExpandServiceTest.java | 51 ++
.../service/process/ProcessServiceTest.java | 62 +-
.../queue/PeerTaskInstancePriorityQueueTest.java | 15 +-
.../dolphinscheduler/spi/utils/JSONUtils.java | 34 +
.../dolphinscheduler/spi}/utils/JSONUtilsTest.java | 132 +---
.../src/main/resources/application.yaml | 56 +-
.../src/main/resources/logback-spring.xml | 4 +-
.../dolphinscheduler-task-all/pom.xml | 12 +
.../plugin/task/api/ProcessUtils.java | 15 +-
.../plugin/task/api/TaskConstants.java | 12 +-
.../plugin/task/api/TaskExecutionContext.java | 414 +---------
.../plugin/task/api/TaskPluginException.java | 17 +-
.../plugin/task/api/enums/ExecutionStatus.java | 23 +
.../plugin/task/api/parser/ParamUtils.java | 85 --
.../plugin/task/api/parser/ParameterUtils.java | 56 --
.../plugin/task/dq/DataQualityTask.java | 15 +-
.../plugin/task/datax/DataxTask.java | 9 +-
.../pom.xml | 14 +-
.../plugin/task/dinky/DinkyParameters.java} | 52 +-
.../plugin/task/dinky/DinkyTask.java | 268 +++++++
.../plugin/task/dinky/DinkyTaskChannel.java} | 14 +-
.../plugin/task/dinky/DinkyTaskChannelFactory.java | 31 +-
.../plugin/task/dinky/DinkyTaskConstants.java | 52 ++
.../plugin/task/dinky/DinkyTaskException.java | 33 +-
.../pom.xml | 2 +-
.../plugin/task/dvc/DvcConstants.java | 56 ++
.../plugin/task/dvc/DvcParameters.java | 105 +++
.../dolphinscheduler/plugin/task/dvc/DvcTask.java | 163 ++++
.../plugin/task/dvc/DvcTaskChannel.java} | 12 +-
.../plugin/task/dvc/DvcTaskChannelFactory.java | 58 ++
.../plugin/task/dvc/TaskTypeEnum.java | 28 +-
.../plugin/task/dvc/DvcTaskTest.java | 153 ++++
.../plugin/task/flink/FileUtils.java | 103 +++
.../plugin/task/flink/FlinkArgsUtils.java | 271 +++++++
.../plugin/task/flink/FlinkConstants.java | 14 +-
.../plugin/task/flink/FlinkDeployMode.java | 24 +-
.../plugin/task/flink/FlinkParameters.java | 8 +-
.../plugin/task/flink/FlinkTask.java | 313 +-------
.../plugin/task/flink/FlinkArgsUtilsTest.java | 132 ++++
.../plugin/task/flink/FlinkTaskTest.java | 116 ---
.../plugin/task/http/HttpTask.java | 8 +-
.../plugin/task/jupyter/JupyterConstants.java | 12 +
.../plugin/task/jupyter/JupyterParameters.java | 20 +
.../plugin/task/jupyter/JupyterTask.java | 18 +-
.../plugin/task/jupyter/JupyterTaskTest.java | 48 +-
.../dolphinscheduler/plugin/task/k8s/K8sTask.java | 8 +-
.../plugin/task/k8s/K8sTaskTest.java | 7 +
.../dolphinscheduler-task-mlflow/pom.xml | 5 +
.../plugin/task/mlflow/MlflowConstants.java | 14 +-
.../plugin/task/mlflow/MlflowParameters.java | 4 +
.../plugin/task/mlflow/MlflowTask.java | 48 +-
.../plugin/task/mlflow/MlflowTaskTest.java | 36 +-
.../plugin/task/mr/MapReduceTask.java | 8 +-
.../plugin/task/procedure/ProcedureTask.java | 2 +-
.../plugin/task/python/PythonTask.java | 9 +-
.../plugin/task/seatunnel/Constants.java | 28 +-
.../plugin/task/seatunnel/DeployModeEnum.java | 26 +-
.../plugin/task/seatunnel/EngineEnum.java | 33 +-
.../plugin/task/seatunnel/SeatunnelParameters.java | 42 +-
.../plugin/task/seatunnel/SeatunnelTask.java | 110 +--
.../task/seatunnel/SeatunnelTaskChannel.java | 10 +-
.../seatunnel/flink/SeatunnelFlinkParameters.java | 58 ++
.../task/seatunnel/flink/SeatunnelFlinkTask.java | 53 ++
.../seatunnel/spark/SeatunnelSparkParameters.java | 90 +++
.../task/seatunnel/spark/SeatunnelSparkTask.java | 73 ++
.../plugin/task/shell/ShellTask.java | 17 +-
.../plugin/task/spark/SparkTask.java | 8 +-
.../dolphinscheduler/plugin/task/sql/SqlTask.java | 4 +-
.../plugin/task/sqoop/SqoopTask.java | 9 +-
.../plugin/task/zeppelin/ZeppelinParameters.java | 2 +-
.../plugin/task/zeppelin/ZeppelinTask.java | 65 +-
.../plugin/task/zeppelin/ZeppelinTaskTest.java | 37 +-
dolphinscheduler-task-plugin/pom.xml | 4 +-
dolphinscheduler-ui/pom.xml | 3 +
.../public/images/task-icons/dinky.png | Bin 0 -> 6447 bytes
.../public/images/task-icons/dinky_hover.png | Bin 0 -> 6330 bytes
.../public/images/task-icons/dvc.png | Bin 0 -> 7649 bytes
.../public/images/task-icons/dvc_hover.png | Bin 0 -> 17007 bytes
dolphinscheduler-ui/src/common/common.ts | 3 +-
dolphinscheduler-ui/src/locales/en_US/project.ts | 22 +-
dolphinscheduler-ui/src/locales/zh_CN/project.ts | 22 +-
dolphinscheduler-ui/src/views/home/index.tsx | 5 +-
.../src/views/projects/overview/index.tsx | 5 +-
.../projects/task/components/node/fields/index.ts | 2 +
.../task/components/node/fields/use-delay-time.ts | 3 +
.../task/components/node/fields/use-deploy-mode.ts | 6 +-
.../node/fields/{use-zeppelin.ts => use-dinky.ts} | 31 +-
.../task/components/node/fields/use-dvc.ts | 171 ++++
.../components/node/fields/use-environment-name.ts | 26 +-
.../task/components/node/fields/use-failed.ts | 6 +
.../task/components/node/fields/use-flink.ts | 68 +-
.../task/components/node/fields/use-jupyter.ts | 57 +-
.../task/components/node/fields/use-k8s.ts | 6 +
.../components/node/fields/use-resource-limit.ts | 4 +-
.../task/components/node/fields/use-resources.ts | 24 +-
.../task/components/node/fields/use-sea-tunnel.ts | 197 +++--
.../task/components/node/fields/use-sqoop.ts | 3 +-
.../task/components/node/fields/use-zeppelin.ts | 9 -
.../projects/task/components/node/format-data.ts | 85 +-
.../projects/task/components/node/tasks/index.ts | 6 +-
.../node/tasks/{use-sea-tunnel.ts => use-dinky.ts} | 17 +-
.../node/tasks/{use-sea-tunnel.ts => use-dvc.ts} | 20 +-
.../task/components/node/tasks/use-sea-tunnel.ts | 28 +-
.../views/projects/task/components/node/types.ts | 14 +-
.../src/views/projects/task/constants/task-type.ts | 10 +
.../workflow/components/dag/dag.module.scss | 12 +
.../workflow/components/dag/use-task-edit.ts | 7 +-
.../workflow/definition/components/start-modal.tsx | 4 +-
.../definition/components/table-action.tsx | 1 -
.../workflow/definition/components/use-form.ts | 2 +-
.../projects/workflow/definition/index.module.scss | 3 +
.../projects/workflow/definition/tree/index.tsx | 5 +
.../projects/workflow/definition/use-table.ts | 1 -
.../src/views/resource/file/rename/index.tsx | 2 +-
.../views/security/alarm-group-manage/index.tsx | 65 +-
.../views/security/alarm-instance-manage/index.tsx | 64 +-
.../src/views/security/cluster-manage/index.tsx | 7 +-
.../views/security/environment-manage/index.tsx | 79 +-
.../views/security/k8s-namespace-manage/index.tsx | 60 +-
.../src/views/security/token-manage/index.tsx | 77 +-
.../views/security/worker-group-manage/index.tsx | 70 +-
.../src/views/security/yarn-queue-manage/index.tsx | 70 +-
.../server/worker/WorkerServer.java | 119 +--
.../server/worker/config/WorkerConfig.java | 148 ++--
.../server/worker/metrics/TaskMetrics.java | 8 +-
.../server/worker/metrics/WorkerServerMetrics.java | 27 +-
.../worker/processor/TaskCallbackService.java | 28 +-
.../worker/processor/TaskExecuteProcessor.java | 153 ++--
.../processor/TaskExecuteRunningAckProcessor.java | 17 +-
.../worker/registry/WorkerRegistryClient.java | 3 +-
.../server/worker/rpc/WorkerRpcServer.java | 97 +++
.../worker/runner/RetryReportTaskStatusThread.java | 88 ++-
.../server/worker/runner/TaskExecuteThread.java | 96 +--
.../server/worker/runner/WorkerManagerThread.java | 3 +-
.../src/main/resources/application.yaml | 13 +-
.../src/main/resources/logback-spring.xml | 6 +-
.../worker/processor/TaskExecuteProcessorTest.java | 46 +-
.../worker/registry/WorkerRegistryClientTest.java | 13 +-
.../worker/runner/TaskExecuteThreadTest.java | 27 +-
images/en_US/dag.png | Bin 79223 -> 83114 bytes
images/en_US/home.png | Bin 96618 -> 119233 bytes
images/en_US/master.png | Bin 72646 -> 76218 bytes
images/zh_CN/dag.png | Bin 78112 -> 81763 bytes
images/zh_CN/home.png | Bin 82523 -> 105634 bytes
images/zh_CN/master.png | Bin 71502 -> 75011 bytes
script/dolphinscheduler-daemon.sh | 2 -
script/env/dolphinscheduler_env.sh | 3 +-
script/env/install_env.sh | 2 +-
script/remove-zk-node.sh | 6 +-
style/checkstyle.xml | 7 +-
539 files changed, 11261 insertions(+), 7788 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/document.yml
create mode 100644 .github/ISSUE_TEMPLATE/improvement-report.yml
create mode 100644 docs/docs/en/about/features.md
create mode 100644 docs/docs/en/development/api-test.md
create mode 100644 docs/docs/en/guide/alert/email.md
create mode 100644 docs/docs/en/guide/datasource/clickhouse.md
create mode 100644 docs/docs/en/guide/datasource/db2.md
delete mode 100644 docs/docs/en/guide/datasource/introduction.md
create mode 100644 docs/docs/en/guide/datasource/oracle.md
create mode 100644 docs/docs/en/guide/datasource/presto.md
create mode 100644 docs/docs/en/guide/datasource/redshift.md
create mode 100644 docs/docs/en/guide/datasource/sql-server.md
create mode 100644 docs/docs/en/guide/healthcheck.md
create mode 100644 docs/docs/en/guide/howto/datasource-setting.md
create mode 100644 docs/docs/en/guide/project/workflow-relation.md
create mode 100644 docs/docs/en/guide/resource/intro.md
create mode 100644 docs/docs/en/guide/task/dinky.md
create mode 100644 docs/docs/en/guide/task/dvc.md
create mode 100644 docs/docs/en/guide/task/seatunnel.md
create mode 100644 docs/docs/zh/about/features.md
create mode 100644 docs/docs/zh/development/api-test.md
create mode 100644 docs/docs/zh/guide/alert/email.md
delete mode 100644 docs/docs/zh/guide/datasource/introduction.md
create mode 100644 docs/docs/zh/guide/healthcheck.md
create mode 100644 docs/docs/zh/guide/howto/datasource-setting.md
create mode 100644 docs/docs/zh/guide/metrics/metrics.md
create mode 100644 docs/docs/zh/guide/resource/intro.md
create mode 100644 docs/docs/zh/guide/task/dinky.md
create mode 100644 docs/docs/zh/guide/task/dvc.md
create mode 100644 docs/docs/zh/guide/task/seatunnel.md
create mode 100644 docs/img/alert/email-alter-setup1-en.png
create mode 100644 docs/img/alert/email-alter-setup2-en.png
create mode 100644 docs/img/alert/email-alter-setup3-en.png
delete mode 100644 docs/img/distributed_lock_procss.png
create mode 100644 docs/img/introduction_ui.png
delete mode 100644 docs/img/metadata-erd/command.png
delete mode 100644 docs/img/metadata-erd/process-task.png
create mode 100644 docs/img/metadata-erd/process_definition.png
create mode 100644 docs/img/metadata-erd/project_tenant_process_definition_schedule.png
create mode 100644 docs/img/new_ui/dev/datasource/ClickHouse.png
create mode 100644 docs/img/new_ui/dev/datasource/DB2.png
create mode 100644 docs/img/new_ui/dev/datasource/oracle.png
create mode 100644 docs/img/new_ui/dev/datasource/presto.png
create mode 100644 docs/img/new_ui/dev/datasource/redshift.png
create mode 100644 docs/img/new_ui/dev/datasource/sql_server.png
create mode 100644 docs/img/new_ui/dev/project/work-relation.png
create mode 100644 docs/img/new_ui/dev/project/workflow-task-run-config.png
create mode 100644 docs/img/new_ui/dev/project/workflow-task-run.png
create mode 100644 docs/img/new_ui/dev/project/workflow_date_manual.png
create mode 100644 docs/img/tasks/demo/dinky.png
create mode 100644 docs/img/tasks/demo/dinky_task_id.png
create mode 100644 docs/img/tasks/demo/dvc_download.png
create mode 100644 docs/img/tasks/demo/dvc_env_config.png
create mode 100644 docs/img/tasks/demo/dvc_env_name.png
create mode 100644 docs/img/tasks/demo/dvc_init.png
create mode 100644 docs/img/tasks/demo/dvc_upload.png
create mode 100644 docs/img/tasks/demo/pre_post_sql.png
create mode 100644 docs/img/tasks/demo/seatunnel_task01.png
create mode 100644 docs/img/tasks/demo/seatunnel_task02.png
create mode 100644 docs/img/tasks/icons/dinky.png
create mode 100644 docs/img/tasks/icons/dvc.png
copy {dolphinscheduler-ui/public/images/task-icons => docs/img/tasks/icons}/seatunnel.png (100%)
copy dolphinscheduler-ui/src/views/security/k8s-namespace-manage/index.module.scss => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/ProcessDefinitionDto.java (79%)
copy dolphinscheduler-ui/src/views/security/worker-group-manage/index.module.scss => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/ProcessInstanceDto.java (79%)
copy dolphinscheduler-ui/src/views/security/token-manage/index.module.scss => dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/security/LdapUserNotExistActionType.java (62%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/{Stopper.java => BaseDaemonThread.java} (65%)
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/LocalJettyHttpServer.java
create mode 100644 dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/utils/LocalServerHttpUtilsTest.java
rename dolphinscheduler-ui/src/views/security/worker-group-manage/index.module.scss => dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/exception/MasterException.java (73%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java => dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/WorkerInfoChangeListener.java (57%)
copy dolphinscheduler-ui/src/views/security/k8s-namespace-manage/index.module.scss => dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowSubmitStatue.java (70%)
delete mode 100644 dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/dispatch/host/RefreshResourceTaskTest.java
rename dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/{WorkflowExecuteTaskTest.java => runner/WorkflowExecuteRunnableTest.java} (92%)
create mode 100644 dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/expand/CuringGlobalParams.java
create mode 100644 dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/expand/CuringParamsService.java
copy dolphinscheduler-ui/src/views/security/environment-manage/index.module.scss => dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/expand/TimePlaceholderResolverExpandService.java (63%)
copy dolphinscheduler-ui/src/views/security/token-manage/index.module.scss => dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/expand/TimePlaceholderResolverExpandServiceImpl.java (63%)
create mode 100644 dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/expand/CuringGlobalParamsServiceTest.java
create mode 100644 dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/expand/TimePlaceholderResolverExpandServiceTest.java
copy {dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common => dolphinscheduler-spi/src/test/java/org/apache/dolphinscheduler/spi}/utils/JSONUtilsTest.java (55%)
rename dolphinscheduler-ui/src/views/security/yarn-queue-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/TaskPluginException.java (79%)
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-mlflow => dolphinscheduler-task-dinky}/pom.xml (82%)
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-zeppelin/src/main/java/org/apache/dolphinscheduler/plugin/task/zeppelin/ZeppelinParameters.java => dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyParameters.java} (54%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyTask.java
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTaskChannel.java => dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyTaskChannel.java} (82%)
copy dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java => dolphinscheduler-task-plugin/dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyTaskChannelFactory.java (54%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyTaskConstants.java
rename dolphinscheduler-ui/src/views/security/token-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-dinky/src/main/java/org/apache/dolphinscheduler/plugin/task/dinky/DinkyTaskException.java (68%)
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-mlflow => dolphinscheduler-task-dvc}/pom.xml (97%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcConstants.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcParameters.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcTask.java
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/SeatunnelTaskChannel.java => dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcTaskChannel.java} (85%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcTaskChannelFactory.java
rename dolphinscheduler-ui/src/views/security/alarm-instance-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/main/java/org/apache/dolphinscheduler/plugin/task/dvc/TaskTypeEnum.java (75%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-dvc/src/test/java/org/apache/dolphinscheduler/plugin/task/dvc/DvcTaskTest.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FileUtils.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtils.java
copy dolphinscheduler-ui/src/views/security/k8s-namespace-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkDeployMode.java (73%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtilsTest.java
delete mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTaskTest.java
rename dolphinscheduler-ui/src/views/security/environment-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/Constants.java (66%)
rename dolphinscheduler-ui/src/views/security/k8s-namespace-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/DeployModeEnum.java (71%)
rename dolphinscheduler-ui/src/views/security/alarm-group-manage/index.module.scss => dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/EngineEnum.java (69%)
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkParameters.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/flink/SeatunnelFlinkTask.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkParameters.java
create mode 100644 dolphinscheduler-task-plugin/dolphinscheduler-task-seatunnel/src/main/java/org/apache/dolphinscheduler/plugin/task/seatunnel/spark/SeatunnelSparkTask.java
create mode 100644 dolphinscheduler-ui/public/images/task-icons/dinky.png
create mode 100644 dolphinscheduler-ui/public/images/task-icons/dinky_hover.png
create mode 100644 dolphinscheduler-ui/public/images/task-icons/dvc.png
create mode 100644 dolphinscheduler-ui/public/images/task-icons/dvc_hover.png
copy dolphinscheduler-ui/src/views/projects/task/components/node/fields/{use-zeppelin.ts => use-dinky.ts} (63%)
create mode 100644 dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-dvc.ts
copy dolphinscheduler-ui/src/views/projects/task/components/node/tasks/{use-sea-tunnel.ts => use-dinky.ts} (84%)
copy dolphinscheduler-ui/src/views/projects/task/components/node/tasks/{use-sea-tunnel.ts => use-dvc.ts} (83%)
create mode 100644 dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/rpc/WorkerRpcServer.java