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 5c37f1efa [INLONG-7126][Sort] Support multiple dirty sink archive
helper (#7127)
new f2fcf934a [INLONG-7133][Dashboard] The sink's data node supports
jumping to the node page (#7137)
new e5351f5c0 [INLONG-7073][Sort] Support table level metrics for Apache
Iceberg connector (#7118)
new 6e6cadb9a [INLONG-7140][Sort] Sort mysql cdc connector mysql snapshot
split exit catch exception (#7141)
new c7af0fcc0 [INLONG-7138][Manager] Support the connection test for
kafka, tube, starrocks, etc (#7142)
The 4 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:
.../src/components/NodeSelect/index.tsx | 59 +++++++++++++++
inlong-dashboard/src/locales/cn.json | 8 +--
inlong-dashboard/src/locales/en.json | 8 +--
.../src/metas/sinks/defaults/ClickHouse.ts | 27 ++-----
.../src/metas/sinks/defaults/Elasticsearch.ts | 26 ++-----
inlong-dashboard/src/metas/sinks/defaults/Hive.ts | 27 ++-----
.../src/metas/sinks/defaults/Iceberg.ts | 27 ++-----
inlong-dashboard/src/metas/sinks/defaults/MySQL.ts | 27 ++-----
.../src/metas/sinks/defaults/StarRocks.ts | 27 ++-----
.../service/cluster/KafkaClusterOperator.java | 25 +++++++
.../service/cluster/TubeClusterOperator.java | 29 +++++++-
.../node/ck/ClickHouseDataNodeOperator.java | 22 ++++++
.../node/iceberg/IcebergDataNodeOperator.java | 23 ++++++
.../service/node/mysql/MySQLDataNodeOperator.java | 23 ++++++
.../node/starrocks/StarRocksDataNodeOperator.java | 24 +++++++
.../sort/base/metric/sub/SinkTableMetricData.java | 13 ++++
.../apache/inlong/sort/iceberg/sink/FlinkSink.java | 2 +-
.../sink/multiple/DynamicSchemaHandleOperator.java | 84 ++++++++++++++++++++--
.../sink/multiple/IcebergMultipleStreamWriter.java | 60 +++-------------
.../sink/multiple/IcebergSingleStreamWriter.java | 10 ++-
.../assigners/MySqlSnapshotSplitAssigner.java | 24 ++++---
21 files changed, 355 insertions(+), 220 deletions(-)
create mode 100644 inlong-dashboard/src/components/NodeSelect/index.tsx
