This is an automated email from the ASF dual-hosted git repository.
huajiang pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
from 35bb533a50 [Improvement][Task Plugin] Integrate zeppelin password
authentication with DS zeppelin task plugin (#13861)
add 79cb707b57 [Improvement-13932][API] Tenant parameters and Worker group
parameters are put together in the task startup parameters (#13935)
No new revisions were added by this update.
Summary of changes:
.../api/controller/ExecutorController.java | 15 ++-
.../controller/ProcessDefinitionController.java | 16 +---
.../api/controller/SchedulerController.java | 17 +++-
.../api/dto/schedule/ScheduleCreateRequest.java | 4 +
.../api/dto/workflow/WorkflowCreateRequest.java | 4 -
.../api/dto/workflow/WorkflowUpdateRequest.java | 6 --
.../apache/dolphinscheduler/api/enums/Status.java | 2 +-
.../dolphinscheduler/api/python/PythonGateway.java | 11 ++-
.../api/service/ExecutorService.java | 9 +-
.../api/service/ProcessDefinitionService.java | 8 --
.../api/service/SchedulerService.java | 6 ++
.../api/service/impl/ExecutorServiceImpl.java | 34 ++++++-
.../service/impl/ProcessDefinitionServiceImpl.java | 105 +++------------------
.../service/impl/ProcessInstanceServiceImpl.java | 18 +---
.../api/service/impl/SchedulerServiceImpl.java | 47 +++++++--
.../api/service/impl/TenantServiceImpl.java | 22 ++---
.../apache/dolphinscheduler/api/vo/ScheduleVo.java | 6 ++
.../controller/ExecuteFunctionControllerTest.java | 15 ++-
.../ProcessDefinitionControllerTest.java | 10 +-
.../api/controller/SchedulerControllerTest.java | 6 +-
.../controller/v2/WorkflowV2ControllerTest.java | 3 -
.../api/service/ExecuteFunctionServiceTest.java | 40 +++++---
.../api/service/ProcessDefinitionServiceTest.java | 28 +-----
.../api/service/ProcessInstanceServiceTest.java | 4 +-
.../service/ProcessTaskRelationServiceTest.java | 1 -
.../api/service/SchedulerServiceTest.java | 6 ++
.../api/service/TenantServiceTest.java | 28 +++---
.../dolphinscheduler/dao/entity/Command.java | 5 +
.../dolphinscheduler/dao/entity/ErrorCommand.java | 5 +
.../dao/entity/ProcessDefinition.java | 20 +---
.../dao/entity/ProcessDefinitionLog.java | 1 -
.../dao/entity/ProcessInstance.java | 2 -
.../dolphinscheduler/dao/entity/Schedule.java | 5 +
.../dao/mapper/ProcessDefinitionMapper.java | 8 --
.../dao/mapper/ProcessInstanceMapper.java | 18 ++--
.../dao/mapper/ScheduleMapper.java | 8 ++
.../dolphinscheduler/dao/upgrade/JsonSplitDao.java | 20 ++--
.../dao/mapper/ProcessDefinitionLogMapper.xml | 4 +-
.../dao/mapper/ProcessDefinitionMapper.xml | 18 +---
.../dao/mapper/ProcessInstanceMapper.xml | 16 ++--
.../dolphinscheduler/dao/mapper/ScheduleMapper.xml | 13 ++-
.../src/main/resources/sql/dolphinscheduler_h2.sql | 8 +-
.../main/resources/sql/dolphinscheduler_mysql.sql | 8 +-
.../resources/sql/dolphinscheduler_postgresql.sql | 8 +-
.../3.2.0_schema/mysql/dolphinscheduler_ddl.sql | 36 ++++++-
.../mysql/dolphinscheduler_ddl_post.sql} | 4 +-
.../3.2.0_schema/mysql/dolphinscheduler_dml.sql | 6 +-
.../postgresql/dolphinscheduler_ddl.sql | 39 +++++++-
.../postgresql/dolphinscheduler_ddl_post.sql} | 4 +-
.../postgresql/dolphinscheduler_dml.sql | 6 +-
.../dao/mapper/ProcessDefinitionMapperTest.java | 21 -----
.../e2e/cases/WorkflowE2ETest.java | 2 -
.../e2e/cases/WorkflowSwitchE2ETest.java | 1 -
.../pages/project/workflow/WorkflowSaveDialog.java | 23 -----
.../master/runner/StreamTaskExecuteRunnable.java | 7 +-
.../master/runner/task/BaseTaskProcessor.java | 4 +-
.../consumer/TaskPriorityQueueConsumerTest.java | 22 +++--
.../runner/task/CommonTaskProcessorTest.java | 2 +-
.../command/task/TaskExecuteStartMessage.java | 2 +-
.../scheduler/quartz/ProcessScheduleTask.java | 1 +
.../service/process/ProcessService.java | 3 +-
.../service/process/ProcessServiceImpl.java | 35 +++----
.../v200/V200DolphinSchedulerUpgrader.java | 2 -
.../v320/V320DolphinSchedulerUpgrader.java | 24 +++--
dolphinscheduler-ui/src/locales/en_US/project.ts | 3 +-
dolphinscheduler-ui/src/locales/zh_CN/project.ts | 3 +-
.../service/modules/process-definition/types.ts | 1 -
.../src/service/modules/process-instances/types.ts | 1 -
.../task/definition/components/start-modal.tsx | 8 ++
.../task/definition/components/use-start.tsx | 13 +++
.../src/views/projects/task/definition/types.ts | 1 +
.../workflow/components/dag/dag-save-modal.tsx | 35 -------
.../workflow/components/dag/dag-startup-param.tsx | 5 +
.../projects/workflow/components/dag/types.ts | 3 +-
.../workflow/definition/components/start-modal.tsx | 38 +++++---
.../definition/components/timing-modal.tsx | 36 ++++---
.../workflow/definition/components/types.ts | 1 +
.../workflow/definition/components/use-form.ts | 2 +
.../workflow/definition/components/use-modal.ts | 13 +++
.../projects/workflow/definition/create/index.tsx | 1 -
.../projects/workflow/definition/detail/index.tsx | 1 -
.../workflow/definition/timing/use-table.ts | 5 +
.../projects/workflow/instance/detail/index.tsx | 1 -
83 files changed, 555 insertions(+), 498 deletions(-)
copy
dolphinscheduler-dao/src/main/resources/sql/upgrade/{1.0.2_schema/mysql/dolphinscheduler_dml.sql
=> 3.2.0_schema/mysql/dolphinscheduler_ddl_post.sql} (83%)
copy
dolphinscheduler-dao/src/main/resources/sql/upgrade/{1.0.2_schema/mysql/dolphinscheduler_dml.sql
=> 3.2.0_schema/postgresql/dolphinscheduler_ddl_post.sql} (82%)
