You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by do...@apache.org on 2022/02/26 09:51:37 UTC

[incubator-inlong] branch master updated (ec322ab -> 429d502)

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 ec322ab  [INLONG-2743][Manager] Support getting inlong workflow error for manager-client module (#2744)
     add 429d502  [INLONG-2677][Manager] Get MQ cluster from database, remove local file configuration dependency (#2740)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/common/beans/ClusterBean.java   | 15 ----
 .../inlong/manager/common/enums/Constant.java      | 10 +++
 .../manager/common/pojo/cluster/ClusterInfo.java   |  6 ++
 .../common/pojo/cluster/DataProxyClusterInfo.java  |  3 +
 .../manager/service/CommonOperateService.java      | 85 +++++++++++++++++++++-
 .../core/impl/DataProxyClusterServiceImpl.java     | 20 +++--
 .../service/core/impl/InlongGroupServiceImpl.java  | 27 +++----
 .../mq/CreatePulsarGroupForStreamTaskListener.java |  7 +-
 .../mq/CreatePulsarGroupTaskListener.java          |  7 +-
 .../mq/CreatePulsarResourceTaskListener.java       |  6 +-
 .../mq/CreatePulsarTopicForStreamTaskListener.java |  6 +-
 .../service/thirdparty/mq/TubeMqOptService.java    | 20 +++--
 .../thirdparty/sort/CreateSortConfigListener.java  | 34 +++++----
 .../thirdparty/sort/PushSortConfigListener.java    | 17 +++--
 .../service/thirdparty/sort/SourceInfoUtils.java   | 15 ++--
 .../ConsumptionCompleteProcessListener.java        |  8 +-
 .../manager-web/sql/apache_inlong_manager.sql      |  4 +-
 .../src/main/resources/application-dev.properties  | 11 ---
 18 files changed, 212 insertions(+), 89 deletions(-)