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 c7af0fcc0 [INLONG-7138][Manager] Support the connection test for
kafka, tube, starrocks, etc (#7142)
new a4f707b60 [INLONG-7149][Manager] Replace tableName in
ClickHouseLoadNode with databaseName.tableName (#7150)
new 871027aa4 [INLONG-7151][Manager] Fix failure to create node when init
sort (#7152)
new d2fe1614c [INLONG-7103][Sort] Support InLongMsg format in Kafka (#7107)
new 903183c6e [INLONG-7144][Manager] Add interface field limit (#7147)
new 9e6782663 [INLONG-7139][Dashboard] Cluster and node support for
connectivity testing (#7145)
new d4b128d63 [INLONG-7153][Dashboard] The data subscription status code
shows the specific meaning (#7155)
new 3db90d470 [INLONG-7154][SDK] Fix metric report failure when topic does
not exist (#7158)
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:
inlong-dashboard/src/locales/cn.json | 5 +-
inlong-dashboard/src/locales/en.json | 5 +-
.../src/metas/consumes/common/status.tsx | 8 +-
.../src/pages/Clusters/CreateModal.tsx | 29 ++++-
inlong-dashboard/src/pages/Nodes/DetailModal.tsx | 30 ++++-
.../manager/pojo/cluster/BindTagRequest.java | 6 +
.../manager/pojo/cluster/ClusterNodeRequest.java | 7 ++
.../manager/pojo/cluster/ClusterRequest.java | 13 ++
.../manager/pojo/cluster/ClusterTagRequest.java | 7 ++
.../manager/pojo/group/InlongGroupExtInfo.java | 8 ++
.../manager/pojo/group/InlongGroupRequest.java | 12 +-
.../pojo/group/InlongGroupResetRequest.java | 5 +-
.../inlong/manager/pojo/node/DataNodeRequest.java | 11 ++
.../inlong/manager/pojo/sink/SinkRequest.java | 16 ++-
.../manager/pojo/sort/util/LoadNodeUtils.java | 2 +-
.../inlong/manager/pojo/source/SourceRequest.java | 14 +++
.../manager/pojo/stream/InlongStreamRequest.java | 14 ++-
.../manager/pojo/transform/TransformRequest.java | 8 ++
.../inlong/manager/pojo/user/UserRequest.java | 10 ++
.../service/sink/mysql/MySQLSinkOperator.java | 10 ++
.../service/source/kafka/KafkaSourceOperator.java | 6 +-
.../apache/inlong/sdk/sort/api/ClientContext.java | 2 +-
.../fetcher/pulsar/PulsarSingleTopicFetcher.java | 138 +++++++++++----------
.../protocol/node/extract/KafkaExtractNode.java | 53 ++++++--
.../node/extract/KafkaExtractNodeTest.java | 22 ++++
25 files changed, 347 insertions(+), 94 deletions(-)
