This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a change to branch k8s/config
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
omit dbdb695c96 Support reading application properties from kubernetes
config map
add b81574ecf2 [Feature-10117][UI] Hide node execution when start from the
workflow definition list page (#11372)
add b3919d30e7 [Improvement-11394][Task Plugin] Remove Passed Parameter
--queue in Seatunnel Task Plugin (#11395)
add 0464123c2b [Feature-11223] support stream task (#11350)
add 6e2bed4d6b [fix-11378] fix API-Server release response message typo
(#11400)
add 6345a13cdc [Fix-10392][SqlTask]: Fix list param error when use sql
task (#11285)
add 5fa3e7b1ed Add pause to task instance status (#11390)
add b79bad19e5 [Fix-11051][Task]Fix the process exitValue exception when
the process times out and th… (#11099)
add 278371bcb9 [doc] Recover traffic configuration (#11288)
add 50380e008f [doc] Add how obtain IP address from network card in FAQ
(#11311)
add f76520c07e [Refactor][UI] Refactor project workflow definition using
NSpace component. (#11398)
add 3836dd7170 [Improvement-11380][scp-host.sh] Set
StrictHostKeyChecking=no option to ssh (#11382)
add 26afd655cb [python] Add multiple version of document (#11391)
add de4e4af844 feat: Modifying Slack Links (#11416)
add 8217784044 [Fix-1360]: Fix Description length check (#11371)
add 496c2d4bfa [Fix-11413] Cannot set task status to kill if the task is
not in running(#11414)
add 16134014f8 [Refactor][UI] Refactor workflow definition timing using
NSpace component. (#11415)
add 20b87ee761 [Refactor][UI] Refactor workflow definition version using
NSpace component. (#11420)
add d02cf85b60 [Fix][UI] fix bug where warn group name not display (#11429)
add 4d427ee215 [python] Add support interpreter version 310 and 311-dev
(#11170)
add 9d6fc92af9 [Doc][Resources] Instruct users to use local storage if
they have remote storage mounted to local (#11435)
add be66035dee [Improvement] Avoid using search in for and start using
testSaveTaskDefine (#11383)
add 47b50067ef Clear thread name in BaseTaskProcessor (#11422)
add abd5798755 [fix-10961][alert server]Change the content of alert to an
array (#11033)
add e3c6ace81d [Doc][DSIP] Move DSIP docs to the right place (#11442)
(#11443)
add dcab16a3eb [Refactor][UI] Refactor task instance batch using NSpace
component. (#11447)
add a2b5219315 Fix find last process instance in dependent task is not
correct (#11424)
add 32361f4fef [Refactor][UI] Refactor workflow instance using NSpace
component. (#11446)
add 376d0a09ae [Improvement-11386][UI] Concise the logic available for
task action buttons (#11419)
add 2240b6e708 [Refactor][UI] Refactor task instance stream using NSpace
component. (#11454)
add 0ca3086296 Fix workflow instance may failover many times due to
doesn't check the restart time (#11445)
add 7ff34c3947 [Feature-7024] Add waiting strategy to support
master/worker can recover from registry lost (#11368)
add 896fef6c98 [Feature][Style] Enable spotless to manage imports (#11458)
add f3d28112ce optimize sorting priority for workflow define (#11462)
add 05589606a2 Set master's task running status in `runTask` to avoid the
task group acquire failed, but the task status is in running (#11451)
add 4362fb8448 If the task processor is not found need to throw error
rather than exception (#11461)
add 13d400ceb6 [Fix-11465] Serial first, the last executing instance will
be stopped (#11466)
add 9d0d4193d9 Support reading application properties from kubernetes
config map
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 (dbdb695c96)
\
N -- N -- N refs/heads/k8s/config (9d0d4193d9)
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/workflows/py-ci.yml | 30 +-
docs/configs/docsdev.js | 4 +-
docs/configs/site.js | 8 +-
docs/docs/en/DSIP.md | 84 ++--
docs/docs/en/architecture/configuration.md | 9 +
docs/docs/en/contribute/have-questions.md | 2 +-
docs/docs/en/faq.md | 6 +
docs/docs/en/guide/project/task-definition.md | 12 +-
docs/docs/en/guide/project/task-instance.md | 16 +-
docs/docs/en/guide/project/workflow-definition.md | 5 +
docs/docs/en/guide/resource/configuration.md | 25 +-
docs/docs/zh/DSIP.md | 86 ++--
docs/docs/zh/architecture/configuration.md | 9 +
docs/docs/zh/contribute/have-questions.md | 2 +-
docs/docs/zh/faq.md | 6 +
docs/docs/zh/guide/project/task-definition.md | 17 +-
docs/docs/zh/guide/project/task-instance.md | 12 +-
docs/docs/zh/guide/project/workflow-definition.md | 4 +
docs/docs/zh/guide/resource/configuration.md | 19 +-
.../new_ui/dev/project/batch-task-definition.png | Bin 0 -> 72426 bytes
.../img/new_ui/dev/project/batch-task-instance.png | Bin 0 -> 73007 bytes
.../new_ui/dev/project/stream-task-definition.png | Bin 0 -> 44125 bytes
.../img/new_ui/dev/project/stream-task-execute.png | Bin 0 -> 66638 bytes
.../new_ui/dev/project/stream-task-instance.png | Bin 0 -> 55423 bytes
docs/img/new_ui/dev/project/task-definition.jpg | Bin 801293 -> 0 bytes
docs/img/new_ui/dev/project/task-instance.png | Bin 84196 -> 0 bytes
.../workflow-definition-with-stream-task.png | Bin 0 -> 35685 bytes
.../alert/email/template/DefaultHTMLTemplate.java | 16 +
.../email/template/DefaultHTMLTemplateTest.java | 8 +
.../dolphinscheduler/alert/AlertSenderService.java | 20 +-
.../apache/dolphinscheduler/alert/AlertServer.java | 5 +-
.../api/controller/ExecutorController.java | 47 ++
.../api/controller/TaskDefinitionController.java | 6 +-
.../api/controller/TaskInstanceController.java | 56 ++-
.../apache/dolphinscheduler/api/enums/Status.java | 15 +-
.../dolphinscheduler/api/service/BaseService.java | 9 +
.../api/service/ExecutorService.java | 18 +
.../api/service/TaskDefinitionService.java | 3 +
.../api/service/TaskInstanceService.java | 22 +
.../api/service/impl/AlertGroupServiceImpl.java | 10 +-
.../api/service/impl/BaseServiceImpl.java | 5 +
.../api/service/impl/ClusterServiceImpl.java | 5 +
.../api/service/impl/DataSourceServiceImpl.java | 8 +
.../api/service/impl/EnvironmentServiceImpl.java | 9 +-
.../api/service/impl/ExecutorServiceImpl.java | 42 ++
.../service/impl/ProcessDefinitionServiceImpl.java | 87 ++--
.../api/service/impl/ProjectServiceImpl.java | 2 +-
.../api/service/impl/ResourcesServiceImpl.java | 18 +
.../service/impl/TaskDefinitionServiceImpl.java | 12 +-
.../api/service/impl/TaskGroupServiceImpl.java | 9 +-
.../api/service/impl/TaskInstanceServiceImpl.java | 79 +++-
.../api/service/impl/TenantServiceImpl.java | 11 +-
.../api/service/impl/UdfFuncServiceImpl.java | 9 +-
.../api/controller/TaskInstanceControllerTest.java | 16 +-
.../api/service/ResourcesServiceTest.java | 18 +-
.../api/service/TaskInstanceServiceTest.java | 110 ++---
dolphinscheduler-bom/pom.xml | 86 ++--
.../apache/dolphinscheduler/common/Constants.java | 29 +-
.../common/enums/ReleaseState.java | 2 +-
.../{ReleaseState.java => TaskExecuteType.java} | 33 +-
.../common/lifecycle/ServerLifeCycleException.java | 18 +-
.../common/lifecycle/ServerLifeCycleManager.java | 75 ++++
.../ServerStatus.java} | 41 +-
.../dolphinscheduler/common/model/TaskNode.java | 27 +-
.../dolphinscheduler/common/thread/Stopper.java | 58 ---
.../dolphinscheduler/common/utils/DateUtils.java | 20 +-
.../common/utils/DateUtilsTest.java | 52 +--
.../dao/entity/TaskDefinition.java | 18 +-
.../dolphinscheduler/dao/entity/TaskInstance.java | 22 +-
.../dao/mapper/TaskDefinitionMapper.java | 5 +-
.../dao/mapper/TaskInstanceMapper.java | 15 +
.../dao/utils/TaskInstanceUtils.java | 1 +
.../dao/mapper/ProcessDefinitionMapper.xml | 2 +-
.../dao/mapper/TaskDefinitionLogMapper.xml | 6 +-
.../dao/mapper/TaskDefinitionMapper.xml | 12 +-
.../dao/mapper/TaskInstanceMapper.xml | 48 +-
.../src/main/resources/sql/dolphinscheduler_h2.sql | 10 +-
.../main/resources/sql/dolphinscheduler_mysql.sql | 10 +-
.../resources/sql/dolphinscheduler_postgresql.sql | 10 +-
.../3.1.0_schema/mysql/dolphinscheduler_ddl.sql | 31 +-
.../mysql/dolphinscheduler_dml.sql | 0
.../postgresql/dolphinscheduler_ddl.sql | 58 +++
.../postgresql/dolphinscheduler_dml.sql | 22 +-
.../dao/mapper/TaskInstanceMapperTest.java | 25 +-
.../server/master/MasterServer.java | 28 +-
.../cache/ProcessInstanceExecCacheManager.java | 3 +
.../cache/StreamTaskInstanceExecCacheManager.java | 52 +++
.../impl/ProcessInstanceExecCacheManagerImpl.java | 8 +-
...=> StreamTaskInstanceExecCacheManagerImpl.java} | 30 +-
.../server/master/config/MasterConfig.java | 53 ++-
.../master/consumer/TaskPriorityQueueConsumer.java | 48 +-
.../dispatch/executor/NettyExecutorManager.java | 12 +-
.../server/master/event/TaskStateEventHandler.java | 4 +-
.../server/master/event/WorkflowEventQueue.java | 3 +
.../server/master/metrics/TaskMetrics.java | 19 +-
.../processor/TaskExecuteStartProcessor.java | 76 ++++
.../processor/queue/StateEventResponseService.java | 4 +-
.../master/processor/queue/TaskEventService.java | 21 +-
.../processor/queue/TaskExecuteThreadPool.java | 9 +
.../master/registry/MasterConnectStrategy.java | 12 +-
.../registry/MasterConnectionStateListener.java | 27 +-
.../master/registry/MasterRegistryClient.java | 94 ++--
.../server/master/registry/MasterStopStrategy.java | 58 +++
.../master/registry/MasterWaitingStrategy.java | 134 ++++++
.../server/master/rpc/MasterRPCServer.java | 14 +-
.../server/master/runner/EventExecuteService.java | 31 +-
.../master/runner/FailoverExecuteThread.java | 9 +-
.../master/runner/MasterSchedulerBootstrap.java | 70 +--
.../master/runner/StateWheelExecuteThread.java | 11 +-
.../master/runner/StreamTaskExecuteRunnable.java | 481 +++++++++++++++++++++
.../master/runner/StreamTaskExecuteThreadPool.java | 79 ++++
.../server/master/runner/WorkflowEventLooper.java | 33 +-
.../master/runner/WorkflowExecuteRunnable.java | 69 +--
.../master/runner/task/BaseTaskProcessor.java | 104 +++--
.../master/runner/task/BlockingTaskProcessor.java | 8 +-
.../master/runner/task/CommonTaskProcessor.java | 10 +-
.../master/runner/task/ConditionTaskProcessor.java | 8 +-
.../master/runner/task/DependentTaskProcessor.java | 2 +-
.../master/runner/task/SwitchTaskProcessor.java | 36 +-
.../master/runner/task/TaskProcessorFactory.java | 4 +
.../master/service/MasterFailoverService.java | 35 +-
.../server/master/utils/DependentExecute.java | 6 -
.../src/main/resources/application.yaml | 7 +-
.../server/master/BlockingTaskTest.java | 2 +-
.../server/master/DependentTaskTest.java | 13 +-
.../server/master/SubProcessTaskTest.java | 8 +-
.../consumer/TaskPriorityQueueConsumerTest.java | 4 +-
.../master/dispatch/ExecutorDispatcherTest.java | 6 +-
.../master/registry/MasterRegistryClientTest.java | 9 +-
.../server/master/service/FailoverServiceTest.java | 7 +-
.../pydolphinscheduler/DEVELOP.md | 23 +-
.../pydolphinscheduler/README.md | 5 +-
.../pydolphinscheduler/docs/Makefile | 5 +
.../docs/source/_templates/versioning.html | 27 ++
.../docs/source/_templates/versions.html | 46 ++
.../pydolphinscheduler/docs/source/api.rst | 4 +-
.../pydolphinscheduler/docs/source/conf.py | 38 +-
.../pydolphinscheduler/setup.py | 10 +-
.../src/pydolphinscheduler/cli/commands.py | 6 +-
.../src/pydolphinscheduler/models/__init__.py | 2 +-
.../pydolphinscheduler/tests/cli/test_version.py | 24 +-
dolphinscheduler-python/pydolphinscheduler/tox.ini | 19 +-
.../registry/api/ConnectStrategy.java | 20 +-
.../registry/api/ConnectStrategyProperties.java | 20 +-
.../dolphinscheduler/registry/api/Registry.java | 11 +
.../registry/api/StrategyType.java | 13 +-
.../plugin/registry/mysql/MysqlRegistry.java | 46 +-
.../registry/mysql/task/EphemeralDateManager.java | 9 +-
.../registry/zookeeper/ZookeeperRegistry.java | 97 +++--
.../remote/command/CommandType.java | 15 +
.../remote/command/TaskExecuteStartCommand.java | 77 ++++
.../command/TaskSavePointRequestCommand.java | 59 ++-
.../command/TaskSavePointResponseCommand.java | 59 ++-
.../command/WorkflowStateEventChangeCommand.java | 2 +
.../remote/dto/TaskInstanceExecuteDto.java | 4 +
.../server/registry/HeartBeatTask.java | 36 +-
.../dolphinscheduler/service/cron/CronUtils.java | 69 ++-
.../service/process/ProcessServiceImpl.java | 45 +-
.../service/registry/RegistryClient.java | 85 +---
.../service/process/ProcessServiceTest.java | 10 +-
.../dolphinscheduler-task-all/pom.xml | 6 +
.../plugin/task/api/AbstractCommandExecutor.java | 56 +--
.../plugin/task/api/AbstractTask.java | 63 ++-
.../plugin/task/api/AbstractYarnTask.java | 12 +-
.../plugin/task/api/TaskConstants.java | 6 +-
.../plugin/task/api/enums/TaskExecutionStatus.java | 7 +-
.../plugin/task/api/parser/ParameterUtils.java | 64 ++-
.../plugin/task/api/stream/StreamTask.java | 12 +-
.../plugin/task/api/stream/StreamTaskChannel.java | 32 +-
.../plugin/task/api/AbstractTaskTest.java | 40 +-
.../plugin/task/api/k8s/K8sTaskExecutorTest.java | 11 -
.../plugin/task/api/parser/ParameterUtilsTest.java | 52 +++
.../plugin/task/chunjun/ChunJunTask.java | 3 +-
.../plugin/task/datax/DataxTask.java | 3 +-
.../dolphinscheduler/plugin/task/dvc/DvcTask.java | 3 +-
.../dolphinscheduler-task-flink-stream/pom.xml | 48 ++
.../plugin/task/flink/FlinkStreamParameters.java | 13 +-
.../plugin/task/flink/FlinkStreamTask.java} | 62 ++-
.../plugin/task/flink/FlinkStreamTaskChannel.java | 59 +++
.../task/flink/FlinkStreamTaskChannelFactory.java | 44 +-
.../plugin/task/flink/FlinkArgsUtilsTest.java | 24 +-
.../plugin/task/flink/FlinkParametersTest.java | 57 +++
.../plugin/task/flink/FlinkArgsUtils.java | 39 +-
.../plugin/task/flink/FlinkConstants.java | 5 +
.../plugin/task/flink/FlinkTask.java | 57 ++-
.../plugin/task/flink/FlinkArgsUtilsTest.java | 12 +-
.../plugin/task/jupyter/JupyterTask.java | 2 +-
.../plugin/task/mlflow/MlflowTask.java | 3 +-
.../plugin/task/python/PythonTask.java | 2 +-
.../plugin/task/seatunnel/SeatunnelTask.java | 3 +-
.../seatunnel/spark/SeatunnelSparkParameters.java | 9 -
.../task/seatunnel/spark/SeatunnelSparkTask.java | 4 -
.../plugin/task/shell/ShellTask.java | 3 +-
.../dolphinscheduler/plugin/task/sql/SqlTask.java | 6 +-
.../plugin/task/zeppelin/ZeppelinTask.java | 11 +-
dolphinscheduler-task-plugin/pom.xml | 1 +
dolphinscheduler-ui/src/common/common.ts | 28 ++
dolphinscheduler-ui/src/locales/en_US/project.ts | 22 +-
dolphinscheduler-ui/src/locales/zh_CN/project.ts | 23 +-
.../src/service/modules/task-definition/index.ts | 27 +-
.../src/service/modules/task-definition/types.ts | 15 +-
.../src/service/modules/task-instances/index.ts | 14 +
.../src/service/modules/task-instances/types.ts | 2 +
.../task/components/node/fields/use-flink.ts | 15 +-
.../task/components/node/fields/use-sea-tunnel.ts | 14 -
.../projects/task/components/node/format-data.ts | 11 +-
.../projects/task/components/node/tasks/index.ts | 4 +-
.../{use-sea-tunnel.ts => use-flink-stream.ts} | 62 +--
.../task/components/node/tasks/use-sea-tunnel.ts | 1 -
.../views/projects/task/components/node/types.ts | 6 +-
.../projects/task/components/node/use-task.ts | 3 +
.../src/views/projects/task/constants/task-type.ts | 16 +-
.../task/definition/{index.tsx => batch-task.tsx} | 18 +-
.../task/definition/components/start-modal.tsx | 267 ++++++++++++
.../task/definition/components/use-start.tsx | 143 ++++++
.../src/views/projects/task/definition/index.tsx | 208 +--------
.../views/projects/task/definition/stream-task.tsx | 159 +++++++
.../src/views/projects/task/definition/types.ts | 14 +-
.../projects/task/definition/use-stream-table.ts | 202 +++++++++
.../src/views/projects/task/definition/use-task.ts | 26 +-
.../task/instance/{index.tsx => batch-task.tsx} | 84 ++--
.../src/views/projects/task/instance/index.tsx | 233 +---------
.../task/instance/{index.tsx => stream-task.tsx} | 127 +++---
.../projects/task/instance/use-stream-table.ts | 357 +++++++++++++++
.../workflow/components/dag/dag-context-menu.tsx | 54 ++-
.../workflow/components/dag/dag-startup-param.tsx | 7 +-
.../workflow/components/dag/dag.module.scss | 6 +-
.../projects/workflow/components/dag/index.tsx | 25 +-
.../workflow/components/dag/use-canvas-init.ts | 18 +-
.../workflow/components/dag/use-cell-active.ts | 16 +-
.../workflow/components/dag/use-cell-update.ts | 2 +-
.../components/dag/use-custom-cell-builder.ts | 38 +-
.../workflow/definition/components/start-modal.tsx | 35 +-
.../workflow/definition/components/use-table.ts | 4 +-
.../definition/components/version-modal.tsx | 34 +-
.../projects/workflow/definition/index.module.scss | 85 ----
.../views/projects/workflow/definition/index.tsx | 209 +++++----
.../projects/workflow/definition/timing/index.tsx | 66 ++-
.../projects/workflow/definition/tree/index.tsx | 7 +-
.../components/process-instance-condition.tsx | 88 ++--
.../projects/workflow/instance/index.module.scss | 80 ----
.../src/views/projects/workflow/instance/index.tsx | 65 ++-
.../server/worker/WorkerServer.java | 49 +--
.../server/worker/config/WorkerConfig.java | 43 +-
.../server/worker/message/MessageRetryRunner.java | 25 +-
.../server/worker/processor/TaskKillProcessor.java | 2 +
.../worker/processor/TaskSavePointProcessor.java | 121 ++++++
.../worker/registry/WorkerConnectStrategy.java | 12 +-
.../registry/WorkerConnectionStateListener.java | 35 +-
.../worker/registry/WorkerRegistryClient.java | 102 ++---
.../server/worker/registry/WorkerStopStrategy.java | 55 +++
.../worker/registry/WorkerWaitingStrategy.java | 135 ++++++
.../server/worker/rpc/WorkerRpcServer.java | 5 +
.../server/worker/runner/WorkerExecService.java | 18 +-
.../server/worker/runner/WorkerManagerThread.java | 35 +-
.../src/main/resources/application.yaml | 7 +-
.../worker/registry/WorkerRegistryClientTest.java | 19 +-
pom.xml | 55 ++-
script/scp-hosts.sh | 4 +-
script/status-all.sh | 8 +-
style/eclipse.importorder | 23 +
261 files changed, 6160 insertions(+), 2781 deletions(-)
create mode 100644 docs/img/new_ui/dev/project/batch-task-definition.png
create mode 100644 docs/img/new_ui/dev/project/batch-task-instance.png
create mode 100644 docs/img/new_ui/dev/project/stream-task-definition.png
create mode 100644 docs/img/new_ui/dev/project/stream-task-execute.png
create mode 100644 docs/img/new_ui/dev/project/stream-task-instance.png
delete mode 100644 docs/img/new_ui/dev/project/task-definition.jpg
delete mode 100644 docs/img/new_ui/dev/project/task-instance.png
create mode 100644
docs/img/new_ui/dev/project/workflow-definition-with-stream-task.png
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/{ReleaseState.java
=> TaskExecuteType.java} (65%)
copy dolphinscheduler-ui/src/views/projects/task/definition/types.ts =>
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/lifecycle/ServerLifeCycleException.java
(72%)
create mode 100644
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/lifecycle/ServerLifeCycleManager.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/{enums/ReleaseState.java
=> lifecycle/ServerStatus.java} (57%)
delete mode 100644
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java
copy dolphinscheduler-ui/src/service/modules/task-instances/index.ts =>
dolphinscheduler-dao/src/main/resources/sql/upgrade/3.1.0_schema/mysql/dolphinscheduler_ddl.sql
(52%)
copy dolphinscheduler-dao/src/main/resources/sql/upgrade/{2.0.4_schema =>
3.1.0_schema}/mysql/dolphinscheduler_dml.sql (100%)
create mode 100644
dolphinscheduler-dao/src/main/resources/sql/upgrade/3.1.0_schema/postgresql/dolphinscheduler_ddl.sql
copy dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss =>
dolphinscheduler-dao/src/main/resources/sql/upgrade/3.1.0_schema/postgresql/dolphinscheduler_dml.sql
(81%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cache/StreamTaskInstanceExecCacheManager.java
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/{ProcessInstanceExecCacheManagerImpl.java
=> StreamTaskInstanceExecCacheManagerImpl.java} (54%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskExecuteStartProcessor.java
copy dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss =>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterConnectStrategy.java
(80%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterStopStrategy.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterWaitingStrategy.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StreamTaskExecuteRunnable.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StreamTaskExecuteThreadPool.java
create mode 100644
dolphinscheduler-python/pydolphinscheduler/docs/source/_templates/versioning.html
create mode 100644
dolphinscheduler-python/pydolphinscheduler/docs/source/_templates/versions.html
copy dolphinscheduler-ui/src/views/projects/task/definition/types.ts =>
dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/ConnectStrategy.java
(74%)
copy dolphinscheduler-ui/src/views/projects/task/definition/types.ts =>
dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/ConnectStrategyProperties.java
(75%)
copy dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss =>
dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/StrategyType.java
(86%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/TaskExecuteStartCommand.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ReleaseState.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/TaskSavePointRequestCommand.java
(51%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/ReleaseState.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/TaskSavePointResponseCommand.java
(51%)
copy dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss =>
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/stream/StreamTask.java
(82%)
copy dolphinscheduler-ui/src/service/modules/task-instances/index.ts =>
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/stream/StreamTaskChannel.java
(52%)
copy dolphinscheduler-ui/src/service/modules/task-instances/index.ts =>
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/AbstractTaskTest.java
(53%)
create mode 100644
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/parser/ParameterUtilsTest.java
create mode 100644
dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/pom.xml
copy dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss =>
dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkStreamParameters.java
(84%)
copy
dolphinscheduler-task-plugin/{dolphinscheduler-task-flink/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTask.java
=>
dolphinscheduler-task-flink-stream/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkStreamTask.java}
(57%)
create mode 100644
dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkStreamTaskChannel.java
copy dolphinscheduler-ui/src/service/modules/task-instances/index.ts =>
dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkStreamTaskChannelFactory.java
(53%)
copy dolphinscheduler-task-plugin/{dolphinscheduler-task-flink =>
dolphinscheduler-task-flink-stream}/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkArgsUtilsTest.java
(79%)
create mode 100644
dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkParametersTest.java
copy
dolphinscheduler-ui/src/views/projects/task/components/node/tasks/{use-sea-tunnel.ts
=> use-flink-stream.ts} (60%)
copy dolphinscheduler-ui/src/views/projects/task/definition/{index.tsx =>
batch-task.tsx} (95%)
create mode 100644
dolphinscheduler-ui/src/views/projects/task/definition/components/start-modal.tsx
create mode 100644
dolphinscheduler-ui/src/views/projects/task/definition/components/use-start.tsx
create mode 100644
dolphinscheduler-ui/src/views/projects/task/definition/stream-task.tsx
create mode 100644
dolphinscheduler-ui/src/views/projects/task/definition/use-stream-table.ts
copy dolphinscheduler-ui/src/views/projects/task/instance/{index.tsx =>
batch-task.tsx} (81%)
copy dolphinscheduler-ui/src/views/projects/task/instance/{index.tsx =>
stream-task.tsx} (69%)
create mode 100644
dolphinscheduler-ui/src/views/projects/task/instance/use-stream-table.ts
delete mode 100644
dolphinscheduler-ui/src/views/projects/workflow/instance/index.module.scss
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskSavePointProcessor.java
rename dolphinscheduler-ui/src/views/projects/task/instance/index.module.scss
=>
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerConnectStrategy.java
(80%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterConnectionStateListener.java
=>
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerConnectionStateListener.java
(58%)
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerStopStrategy.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerWaitingStrategy.java
create mode 100644 style/eclipse.importorder
