This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 0d7826c [INLONG-2333] Support clickhouse sink in sort-single-tenant
(#2355)
add 5d2e4e6 [INLONG-2373] Refactor of CreateBusinessWorkflow (#2374)
No new revisions were added by this update.
Summary of changes:
.../common/event/task/TaskEventNotifier.java | 13 +-
.../common/model/definition/ServiceTask.java | 40 ++++-
...ement.java => ServiceTaskListenerProvider.java} | 13 +-
.../{EndEvent.java => ServiceTaskType.java} | 22 +--
.../manager/common/model/definition/Task.java | 11 +-
inlong-manager/manager-service/pom.xml | 5 +
...actory.java => ServiceTaskListenerFactory.java} | 42 ++++-
.../service/workflow/WorkflowServiceImpl.java | 2 +
.../business/CreateBusinessWorkflowDefinition.java | 176 ++++++---------------
...st.java => ServiceTaskListenerFactoryTest.java} | 8 +-
.../service/workflow/WorkflowServiceImplTest.java | 162 +++++++++++++++++++
.../CreateBusinessWorkflowDefinitionTest.java | 7 +-
.../core/processor/ServiceTaskProcessor.java | 2 +-
inlong-manager/pom.xml | 7 +
14 files changed, 334 insertions(+), 176 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/model/definition/{SkippableElement.java
=> ServiceTaskListenerProvider.java} (75%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/model/definition/{EndEvent.java
=> ServiceTaskType.java} (76%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/{TaskEventListenerFactory.java
=> ServiceTaskListenerFactory.java} (79%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/{TaskEventListenerFactoryTest.java
=> ServiceTaskListenerFactoryTest.java} (89%)
create mode 100644
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/workflow/WorkflowServiceImplTest.java