This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch branch-1.5
in repository https://gitbox.apache.org/repos/asf/inlong.git
from e719c62b5 [INLONG-7163][Dashboard] Data subscription addition and
details page optimization (#7179)
new d2ef58778 [INLONG-7178][Manager] Optimize parameter checks for
InlongGroup, and simplify the exception and log info (#7180)
new f06a60a40 [INLONG-7182][TubeMQ] Replace ParamCheckResult with
ProcessResult (#7183)
new 6cc584bbc [INLONG-7184][TubeMQ] Replace CertifiedResult with
ProcessResult (#7185)
new 61ce6e296 [INLONG-5776][Manager] Add tenant param to InlongGroup that
uses Pulsar (#7171)
new 7d69c0e4c [INLONG-7188][Doc] Change the project Copyright to 2019-2023
(#7189)
new 3652e3973 [INLONG-7186][Sort] Fix time zone incorrect (#7187)
new b5f562144 [INLONG-7190][Dashboard] New data subscription optimization
(#7196)
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
NOTICE | 2 +-
.../metas/consumes/common/ConsumeDefaultInfo.ts | 43 +-
.../src/pages/ConsumeDetail/Info/config.tsx | 28 -
.../src/pages/ConsumeDetail/Info/index.tsx | 27 +-
.../apache/inlong/manager/client/BaseExample.java | 2 -
.../apache/inlong/manager/client/ut/BaseTest.java | 2 -
.../client/api/inner/ClientFactoryTest.java | 1 -
.../inlong/manager/common/enums/ErrorCodeEnum.java | 1 +
.../inlong/manager/common/enums/GroupStatus.java | 5 +-
.../resources/mappers/InlongGroupEntityMapper.xml | 7 +-
.../pojo/cluster/kafka/KafkaClusterDTO.java | 15 +-
.../pojo/cluster/pulsar/PulsarClusterDTO.java | 17 +-
.../pojo/cluster/pulsar/PulsarClusterInfo.java | 4 +-
.../pojo/cluster/pulsar/PulsarClusterRequest.java | 3 +-
.../manager/pojo/group/InlongGroupBriefInfo.java | 5 +-
.../manager/pojo/group/InlongGroupRequest.java | 16 +-
.../manager/pojo/group/kafka/InlongKafkaDTO.java | 3 +-
.../manager/pojo/group/pulsar/InlongPulsarDTO.java | 8 +-
.../pojo/group/pulsar/InlongPulsarInfo.java | 6 -
.../pojo/group/pulsar/InlongPulsarRequest.java | 7 +
.../manager/pojo/group/tubemq/InlongTubeMQDTO.java | 3 +-
.../pojo/source/autopush/AutoPushSourceDTO.java | 3 +-
.../manager/pojo/source/file/FileSourceDTO.java | 3 +-
.../manager/pojo/source/hudi/HudiSourceDTO.java | 3 +-
.../manager/pojo/source/kafka/KafkaSourceDTO.java | 3 +-
.../pojo/source/mongodb/MongoDBSourceDTO.java | 3 +-
.../manager/pojo/source/mqtt/MqttSourceDTO.java | 3 +-
.../pojo/source/mysql/MySQLBinlogSourceDTO.java | 3 +-
.../pojo/source/oracle/OracleSourceDTO.java | 3 +-
.../source/postgresql/PostgreSQLSourceDTO.java | 3 +-
.../pojo/source/pulsar/PulsarSourceDTO.java | 3 +-
.../manager/pojo/source/redis/RedisSourceDTO.java | 3 +-
.../pojo/source/sqlserver/SQLServerSourceDTO.java | 3 +-
.../pojo/source/tubemq/TubeMQSourceDTO.java | 3 +-
.../service/cluster/InlongClusterServiceImpl.java | 25 +-
.../service/cluster/KafkaClusterOperator.java | 2 -
.../service/cluster/PulsarClusterOperator.java | 2 -
.../service/consume/ConsumePulsarOperator.java | 14 +-
.../service/core/impl/AgentServiceImpl.java | 105 ++--
.../service/group/AbstractGroupOperator.java | 7 +-
.../service/group/InlongGroupOperator4Kafka.java | 4 +-
.../service/group/InlongGroupOperator4NoneMQ.java | 2 +-
.../service/group/InlongGroupOperator4Pulsar.java | 32 +-
.../service/group/InlongGroupOperator4TubeMQ.java | 3 +-
.../service/group/InlongGroupOperatorFactory.java | 3 +-
.../service/group/InlongGroupServiceImpl.java | 28 +-
.../apply/ApproveConsumeProcessListener.java | 18 +-
.../queue/pulsar/PulsarResourceOperator.java | 42 +-
.../source/pulsar/PulsarSourceOperator.java | 15 +-
.../service/cluster/InlongClusterServiceTest.java | 1 -
.../service/consume/InlongConsumeServiceTest.java | 2 -
.../web/controller/InlongGroupController.java | 3 +-
.../openapi/OpenInLongGroupController.java | 3 +-
.../sort/base/format/JsonToRowDataConverters.java | 7 +-
.../tubemq/server/broker/BrokerServiceServer.java | 101 ++--
.../common/aaaserver/CertificateBrokerHandler.java | 13 +-
.../common/aaaserver/CertificateMasterHandler.java | 15 +-
.../{CertifiedResult.java => CertifiedInfo.java} | 42 +-
.../aaaserver/SimpleCertificateBrokerHandler.java | 61 +-
.../aaaserver/SimpleCertificateMasterHandler.java | 103 ++--
.../server/common/paramcheck/PBParameterUtils.java | 226 +++-----
.../server/common/paramcheck/ParamCheckResult.java | 60 --
.../inlong/tubemq/server/master/TMaster.java | 639 +++++++++------------
.../nodemanage/nodeconsumer/ConsumeGroupInfo.java | 105 ++--
.../nodeconsumer/ConsumerInfoHolder.java | 14 +-
.../tubemq/server/common/PBParameterTest.java | 45 +-
licenses/NOTICE | 2 +-
licenses/inlong-agent/NOTICE | 2 +-
licenses/inlong-audit/NOTICE | 2 +-
licenses/inlong-dashboard/NOTICE | 2 +-
licenses/inlong-dataproxy/NOTICE | 2 +-
licenses/inlong-manager/NOTICE | 2 +-
licenses/inlong-sort-connectors/NOTICE | 2 +-
licenses/inlong-sort-standalone/NOTICE | 2 +-
licenses/inlong-sort/NOTICE | 2 +-
licenses/inlong-tubemq-manager/NOTICE | 2 +-
licenses/inlong-tubemq-server/NOTICE | 2 +-
77 files changed, 914 insertions(+), 1094 deletions(-)
rename
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/aaaserver/{CertifiedResult.java
=> CertifiedInfo.java} (53%)
delete mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/paramcheck/ParamCheckResult.java
