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%)