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 9bd8781f3 [INLONG-7206][Manager] Fix the problem of the
selectBriefList method in the InlongGroupEntity.xml file is incorrect (#7207)
new 93dde1fb9 [INLONG-7199][Manager] Support save extension params for
inlong cluster node (#7200)
new b2a2a2301 [INLONG-7252][Sort] Fix Doris connector throw NPE when DATE
type data is null (#7259)
The 2 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:
.../manager/common/consts/AgentConstants.java | 26 --------
.../dao/mapper/InlongClusterNodeEntityMapper.java | 2 +
.../mappers/InlongClusterNodeEntityMapper.xml | 41 +++++++++++++
.../manager/pojo/cluster/ClusterNodeRequest.java | 3 +-
...entClusterDTO.java => AgentClusterNodeDTO.java} | 25 ++++----
...erRequest.java => AgentClusterNodeRequest.java} | 14 ++---
...rRequest.java => AgentClusterNodeResponse.java} | 14 ++---
.../service/cluster/InlongClusterServiceImpl.java | 45 +++++---------
.../AbstractClusterNodeOperator.java} | 47 +++++++--------
.../AgentClusterNodeOperator.java} | 54 ++++++++---------
.../cluster/node/DefaultClusterNodeOperator.java | 60 +++++++++++++++++++
.../InlongClusterNodeOperator.java} | 44 +++++---------
.../InlongClusterNodeOperatorFactory.java} | 25 ++++----
.../service/core/impl/AgentServiceImpl.java | 70 ++++++++++++----------
.../service/heartbeat/HeartbeatManager.java | 23 +++----
.../table/DorisDynamicSchemaOutputFormat.java | 7 ++-
16 files changed, 283 insertions(+), 217 deletions(-)
delete mode 100644
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/AgentConstants.java
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/{AgentClusterDTO.java
=> AgentClusterNodeDTO.java} (72%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/{AgentClusterRequest.java
=> AgentClusterNodeRequest.java} (78%)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/{AgentClusterRequest.java
=> AgentClusterNodeResponse.java} (78%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/{AbstractClusterOperator.java
=> node/AbstractClusterNodeOperator.java} (58%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/{AgentClusterOperator.java
=> node/AgentClusterNodeOperator.java} (56%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/DefaultClusterNodeOperator.java
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/{InlongClusterOperator.java
=> node/InlongClusterNodeOperator.java} (55%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/{InlongClusterOperatorFactory.java
=> node/InlongClusterNodeOperatorFactory.java} (57%)
