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/inlong.git
from 27b1a02fc [INLONG-5299][Manager] Remove redundant configuration and
class files (#5300)
add 290e87f01 [INLONG-5296][Manager] Add fields for DataNode and
InlongCluster (#5297)
No new revisions were added by this update.
Summary of changes:
.../client/api/inner/ClientFactoryTest.java | 2 +-
.../inlong/manager/common/enums/ClusterType.java | 4 +-
.../inlong/manager/common/enums/ErrorCodeEnum.java | 1 +
.../inlong/manager/dao/entity/DataNodeEntity.java | 3 +-
.../manager/dao/entity/InlongClusterEntity.java | 1 +
.../dao/entity/InlongClusterNodeEntity.java | 1 +
.../manager/dao/entity/InlongClusterTagEntity.java | 2 +
.../manager/dao/mapper/DataNodeEntityMapper.java | 3 +-
.../dao/mapper/InlongClusterNodeEntityMapper.java | 2 -
.../dao/mapper/InlongClusterTagEntityMapper.java | 2 -
.../main/resources/mappers/ClusterSetMapper.xml | 2 +-
.../resources/mappers/DataNodeEntityMapper.xml | 60 +++++++++++-----------
.../mappers/InlongClusterEntityMapper.xml | 23 +++++----
.../mappers/InlongClusterNodeEntityMapper.xml | 49 ++++--------------
.../mappers/InlongClusterTagEntityMapper.xml | 46 ++++-------------
.../resources/mappers/StreamSinkEntityMapper.xml | 2 +-
.../inlong/manager/pojo/cluster/ClusterInfo.java | 5 +-
.../manager/pojo/cluster/ClusterNodeRequest.java | 5 +-
.../manager/pojo/cluster/ClusterNodeResponse.java | 11 ++--
.../manager/pojo/cluster/ClusterPageRequest.java | 2 +-
.../manager/pojo/cluster/ClusterRequest.java | 5 +-
.../manager/pojo/cluster/ClusterTagRequest.java | 3 ++
.../manager/pojo/cluster/ClusterTagResponse.java | 3 ++
.../DataProxyClusterDTO.java} | 36 +++++++------
.../cluster/dataproxy/DataProxyClusterInfo.java | 16 ++++--
.../cluster/dataproxy/DataProxyClusterRequest.java | 16 ++++--
.../pojo/cluster/pulsar/PulsarClusterDTO.java | 2 +-
.../pojo/cluster/tubemq/TubeClusterDTO.java | 2 +-
.../pojo/cluster/tubemq/TubeClusterInfo.java | 4 +-
.../pojo/cluster/tubemq/TubeClusterRequest.java | 4 +-
.../inlong/manager/pojo/node/DataNodeRequest.java | 3 ++
.../inlong/manager/pojo/node/DataNodeResponse.java | 3 ++
.../service/cluster/DataProxyClusterOperator.java | 2 +-
.../service/cluster/InlongClusterServiceImpl.java | 56 +++++++++-----------
.../service/cluster/TubeClusterOperator.java | 2 +-
.../ConsumptionCompleteProcessListener.java | 2 +-
.../queue/tubemq/TubeMQResourceOperator.java | 2 +-
.../source/tubemq/TubeMQSourceOperator.java | 2 +-
.../common/utils/ValidationUtilsTest.java | 2 +-
.../service/cluster/InlongClusterServiceTest.java | 6 +--
.../service/core/impl/DataNodeServiceTest.java | 1 +
.../InlongGroupProcessServiceTest.java | 6 +--
.../{mq/util => queue}/PulsarUtilsTest.java | 2 +-
.../repository/DataProxyConfigRepositoryTest.java | 2 +-
.../{core => }/sink/ClickHouseSinkServiceTest.java | 3 +-
.../{core => }/sink/DLCIcebergSinkServiceTest.java | 3 +-
.../sink/ElasticsearchSinkServiceTest.java | 3 +-
.../{core => }/sink/GreenplumSinkServiceTest.java | 3 +-
.../{core => }/sink/HBaseSinkServiceTest.java | 3 +-
.../{core => }/sink/HDFSStreamSinkServiceTest.java | 3 +-
.../{core => }/sink/HiveSinkServiceTest.java | 3 +-
.../{core => }/sink/IcebergSinkServiceTest.java | 3 +-
.../{core => }/sink/KafkaSinkServiceTest.java | 3 +-
.../{core => }/sink/MySQLSinkServiceTest.java | 3 +-
.../sink/MySQLStreamSinkServiceTest.java | 3 +-
.../{core => }/sink/OracleSinkServiceTest.java | 3 +-
.../{core => }/sink/PostgreSQLSinkServiceTest.java | 3 +-
.../{core => }/sink/SQLServerSinkServiceTest.java | 3 +-
.../sink/TDSQLPostgreSQLSinkServiceTest.java | 3 +-
.../{core/impl => sort}/SortServiceImplTest.java | 2 +-
.../{core => }/source/TubeMQSourceServiceTest.java | 3 +-
.../main/resources/h2/apache_inlong_manager.sql | 20 +++++---
.../manager-web/sql/apache_inlong_manager.sql | 13 ++---
63 files changed, 229 insertions(+), 262 deletions(-)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/{pulsar/PulsarClusterDTO.java
=> dataproxy/DataProxyClusterDTO.java} (62%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/{pojo =>
}/common/utils/ValidationUtilsTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core/impl
=> group}/InlongGroupProcessServiceTest.java (95%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{mq/util
=> queue}/PulsarUtilsTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/ClickHouseSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/DLCIcebergSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/ElasticsearchSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/GreenplumSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/HBaseSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/HDFSStreamSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/HiveSinkServiceTest.java (96%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/IcebergSinkServiceTest.java (96%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/KafkaSinkServiceTest.java (96%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/MySQLSinkServiceTest.java (98%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/MySQLStreamSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/OracleSinkServiceTest.java (98%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/PostgreSQLSinkServiceTest.java (98%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/SQLServerSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/sink/TDSQLPostgreSQLSinkServiceTest.java (97%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core/impl
=> sort}/SortServiceImplTest.java (99%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core
=> }/source/TubeMQSourceServiceTest.java (96%)
