This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from f5d597e6f [INLONG-6371][Manager] Fix the lack of topic and cache zone
properties in getSortSource (#6372)
add a34a33b5c [INLONG-6376][Agent] Refactor sink and complement send
metric (#6377)
No new revisions were added by this update.
Summary of changes:
.../inlong/agent/message/BatchProxyMessage.java | 23 ++--
.../agent/plugin/message/PackProxyMessage.java | 44 ++++---
.../inlong/agent/plugin/sinks/AbstractSink.java | 2 +
.../inlong/agent/plugin/sinks/ProxySink.java | 48 ++------
.../inlong/agent/plugin/sinks/SenderManager.java | 126 +++++++++++----------
.../inlong/common/msg/AttributeConstants.java | 1 +
.../inlong/sdk/dataproxy/utils/ProxyUtils.java | 4 +
7 files changed, 124 insertions(+), 124 deletions(-)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/sdk/CacheZone.java =>
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/BatchProxyMessage.java
(71%)
