[incubator-inlong] branch master updated (c5b3c19 -> fa0df17)

[he...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from c5b3c19  [INGLONG-2756][agent]Add more logs when sending data to proxy #2756 (#2757)
     add fa0df17  [INLONG-2676][Manager] Support stop / restart / finish agent task (#2705)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/common/enums/GroupState.java    |  32 +++---
 .../inlong/manager/common/enums/SourceState.java   |  74 +++++++++++++
 .../manager/common/pojo/source/SourceRequest.java  |   1 -
 .../pojo/source/binlog/BinlogSourceRequest.java    |   5 +
 .../pojo/source/kafka/KafkaSourceRequest.java      |   5 +
 .../service/core/impl/InlongGroupServiceImpl.java  |  21 ++--
 .../source/AbstractStreamSourceOperation.java      |  57 +++++++++--
 .../service/source/StreamSourceOperation.java      |  24 +++++
 .../service/source/StreamSourceService.java        |  21 +++-
 .../service/source/StreamSourceServiceImpl.java    |  66 ++++++++----
 .../listener/AbstractSourceOperateListener.java    | 114 +++++++++++++++++++++
 .../listener/SourceDeleteEventSelector.java}       |  23 ++---
 .../source/listener/SourceDeleteListener.java}     |  17 ++-
 .../listener/SourceRestartEventSelector.java}      |  23 ++---
 .../source/listener/SourceRestartListener.java}    |  15 ++-
 .../listener/SourceStopEventSelector.java}         |  23 ++---
 .../source/listener/SourceStopListener.java}       |  15 ++-
 .../thirdparty/sort/CreateSortConfigListener.java  |  15 ++-
 .../thirdparty/sort/PushSortConfigListener.java    |   6 +-
 .../sort/{utils => util}/SerializationUtils.java   |   2 +-
 .../sort/{utils => util}/SinkInfoUtils.java        |   2 +-
 .../sort/{utils => util}/SortFieldFormatUtils.java |   2 +-
 .../sort/{utils => util}/SourceInfoUtils.java      |   2 +-
 .../workflow/ServiceTaskListenerFactory.java       |  21 ++++
 .../group/SuspendGroupWorkflowDefinition.java      |   2 +-
 .../core/impl/InlongGroupProcessOperationTest.java |  26 +++--
 .../source/listener/DataSourceListenerTest.java    | 104 +++++++++++++++++++
 .../thirdparty/sort/DisableZkForSortTest.java      |  30 +-----
 .../service/workflow/WorkflowServiceImplTest.java  |  69 ++++++++++---
 inlong-manager/manager-test/pom.xml                |   5 +
 .../org/apache/inlong/manager/test/BaseTest.java   |  11 ++
 .../src/main/resources/application-test.properties |   2 +-
 .../resources/db/migration/h2/V0__functions.sql}   |   7 +-
 .../main/resources/sql/apache_inlong_manager.sql   |   2 +-
 inlong-manager/pom.xml                             |   6 ++
 35 files changed, 661 insertions(+), 189 deletions(-)
 create mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/SourceState.java
 create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/listener/AbstractSourceOperateListener.java
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{thirdparty/sort/ZkEnabledEventSelector.java => source/listener/SourceDeleteEventSelector.java} (59%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/conversion/HoursToMinute.java => manager-service/src/main/java/org/apache/inlong/manager/service/source/listener/SourceDeleteListener.java} (63%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{thirdparty/sort/ZkEnabledEventSelector.java => source/listener/SourceRestartEventSelector.java} (59%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/conversion/HoursToMinute.java => manager-service/src/main/java/org/apache/inlong/manager/service/source/listener/SourceRestartListener.java} (64%)
 copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{thirdparty/sort/ZkEnabledEventSelector.java => source/listener/SourceStopEventSelector.java} (59%)
 copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/conversion/HoursToMinute.java => manager-service/src/main/java/org/apache/inlong/manager/service/source/listener/SourceStopListener.java} (65%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{utils => util}/SerializationUtils.java (99%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{utils => util}/SinkInfoUtils.java (99%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{utils => util}/SortFieldFormatUtils.java (98%)
 rename inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{utils => util}/SourceInfoUtils.java (98%)
 create mode 100644 inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/source/listener/DataSourceListenerTest.java
 copy inlong-manager/{manager-workflow/src/main/java/org/apache/inlong/manager/workflow/plugin/Plugin.java => manager-test/src/main/resources/db/migration/h2/V0__functions.sql} (86%)