You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/10/18 09:38:53 UTC

[inlong] branch master updated (1b3c5afe9 -> 5a1155797)

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%)