You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/03/09 07:17:12 UTC

[incubator-inlong] branch master updated (8684a9f -> 7327a6e)

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 8684a9f  [INLONG-3009][Sort] Support TDMQ pulsar source (#3010)
     add 7327a6e  [INLONG-3007][Manager] Add enable_create_resource for mq conf (#3008)

No new revisions were added by this update.

Summary of changes:
 .../common/pojo/dataproxy/PulsarClusterInfo.java   |  2 +-
 .../manager/client/api/InlongStreamConf.java       |  3 ++
 .../inlong/manager/client/api/MqBaseConf.java      | 19 ++-------
 .../inlong/manager/client/api/PulsarBaseConf.java  |  4 ++
 .../inlong/manager/client/api/TubeBaseConf.java    |  1 +
 .../client/api/util/InlongGroupTransfer.java       | 13 +++---
 .../client/api/util/InlongStreamTransfer.java      |  7 +++-
 .../inlong/manager/common/enums/Constant.java      |  2 +
 .../enums/{ProcessStatus.java => MqType.java}      | 40 ++++++------------
 .../common/pojo/group/InlongGroupMqExtBase.java    |  3 ++
 .../common/pojo/group/InlongGroupPulsarInfo.java   |  3 ++
 .../dao/entity/InlongGroupPulsarEntity.java        |  3 +-
 .../mappers/InlongGroupPulsarEntityMapper.xml      | 47 ++++++++++++++++++----
 .../manager/service/CommonOperateService.java      |  1 +
 .../core/impl/DataProxyClusterServiceImpl.java     | 24 +++++++----
 .../service/thirdparty/mq/PulsarEventSelector.java |  4 +-
 .../thirdparty/sort/CreateSortConfigListener.java  | 20 +++++----
 .../thirdparty/sort/PushSortConfigListener.java    | 11 ++++-
 .../thirdparty/sort/util/SourceInfoUtils.java      | 28 ++++++++++---
 .../main/resources/sql/apache_inlong_manager.sql   |  2 +
 .../manager-web/sql/apache_inlong_manager.sql      |  2 +
 21 files changed, 156 insertions(+), 83 deletions(-)
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/{ProcessStatus.java => MqType.java} (70%)