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 1b3c5afe9 [INLONG-6160][Sort] Support dynamic partition for
KafkaLoadNode (#6165)
add 5a1155797 [INLONG-6181][Agent][DataProxy][Manager] Support node
protocol reporting and query (#6184)
No new revisions were added by this update.
Summary of changes:
.../apache/inlong/agent/core/HeartbeatManager.java | 2 +-
.../inlong/agent/plugin/sinks/SenderManager.java | 5 +-
.../inlong/common/constant}/ProtocolType.java | 2 +-
.../common/heartbeat/ComponentHeartbeat.java | 4 +-
.../inlong/common/heartbeat/HeartbeatMsg.java | 2 +-
inlong-dataproxy/conf/common.properties | 12 ++-
inlong-dataproxy/conf/dataproxy-pulsar.conf | 25 +++++-
inlong-dataproxy/conf/dataproxy-tube.conf | 33 ++++++--
inlong-dataproxy/dataproxy-docker/Dockerfile | 2 +-
.../dataproxy-docker/dataproxy-docker.sh | 1 +
.../inlong/dataproxy/consts/ConfigConstants.java | 1 +
.../dataproxy/heartbeat/HeartbeatManager.java | 8 +-
.../mappers/InlongClusterNodeEntityMapper.xml | 7 +-
.../manager/pojo/cluster/ClusterPageRequest.java | 3 +
.../service/core/heartbeat/HeartbeatManager.java | 90 ++++++++++++++++------
.../service/cluster/InlongClusterServiceTest.java | 10 ++-
.../core/heartbeat/HeartbeatManagerTest.java | 8 +-
.../service/core/impl/HeartbeatServiceTest.java | 7 +-
.../main/resources/h2/apache_inlong_manager.sql | 2 +-
.../manager-web/sql/apache_inlong_manager.sql | 2 +-
20 files changed, 172 insertions(+), 54 deletions(-)
rename
{inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts
=>
inlong-common/src/main/java/org/apache/inlong/common/constant}/ProtocolType.java
(95%)
