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 43b821ac4 [INLONG-7166][DataProxy] Fix audit data reporting (#7167)
new dabfef741 [INLONG-7161][Sort] Fix bug that Mysql connector only output
the latest record in snapshot stage for table without primary key (Supplement)
(#7175)
new 7cb6f77f3 [INLONG-7172][Sort] Fix new table write into iceberg failed
(#7173)
new c5d98cfeb [INLONG-7169][Manager] Optimize OpenDataNodeController
implementation (#7170)
new 933828234 [INLONG-7176][Dashboard] Data flow group adds restart and
stop state operations (#7177)
new e719c62b5 [INLONG-7163][Dashboard] Data subscription addition and
details page optimization (#7179)
The 5 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 | 8 +++
inlong-dashboard/src/locales/en.json | 8 +++
.../metas/consumes/common/ConsumeDefaultInfo.ts | 45 ++++++++++------
.../src/metas/consumes/defaults/Pulsar.ts | 4 +-
.../src/pages/ConsumeDetail/Info/config.tsx | 28 ++++++++++
.../src/pages/ConsumeDetail/Info/index.tsx | 11 +++-
inlong-dashboard/src/pages/ConsumeDetail/index.tsx | 4 +-
.../src/pages/GroupDashboard/config.tsx | 12 ++++-
.../src/pages/GroupDashboard/index.tsx | 36 ++++++++++++-
...teValidation.java => UpdateByIdValidation.java} | 2 +-
...eValidation.java => UpdateByKeyValidation.java} | 6 +--
.../manager/pojo/node/DataNodePageRequest.java | 6 +++
.../inlong/manager/pojo/node/DataNodeRequest.java | 16 +++---
.../pojo/node/ck/ClickHouseDataNodeDTO.java | 3 +-
.../pojo/node/es/ElasticsearchDataNodeDTO.java | 4 +-
.../manager/pojo/node/hive/HiveDataNodeDTO.java | 4 +-
.../manager/pojo/node/hudi/HudiDataNodeDTO.java | 4 +-
.../pojo/node/iceberg/IcebergDataNodeDTO.java | 4 +-
.../manager/pojo/node/mysql/MySQLDataNodeDTO.java | 3 +-
.../pojo/node/starrocks/StarRocksDataNodeDTO.java | 3 +-
.../service/node/AbstractDataNodeOperator.java | 7 +--
.../service/node/DataNodeOperatorFactory.java | 1 +
.../manager/service/node/DataNodeServiceImpl.java | 62 ++++++++++++++--------
.../node/ck/ClickHouseDataNodeOperator.java | 4 +-
.../node/es/ElasticsearchDataNodeOperator.java | 7 +--
.../service/node/hive/HiveDataNodeOperator.java | 7 +--
.../service/node/hudi/HudiDataNodeOperator.java | 6 +--
.../node/iceberg/IcebergDataNodeOperator.java | 7 +--
.../service/node/mysql/MySQLDataNodeOperator.java | 7 +--
.../node/starrocks/StarRocksDataNodeOperator.java | 7 +--
.../manager/web/controller/DataNodeController.java | 11 ++--
.../controller/openapi/OpenDataNodeController.java | 14 ++---
.../web/controller/DataNodeControllerTest.java | 1 -
.../sink/multiple/IcebergSingleFileCommiter.java | 3 +-
.../mysql/debezium/reader/BinlogSplitReader.java | 3 +-
35 files changed, 243 insertions(+), 115 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/validation/{UpdateValidation.java
=> UpdateByIdValidation.java} (95%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/validation/{UpdateValidation.java
=> UpdateByKeyValidation.java} (89%)
