This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 5c6690cfe [INLONG-5474][Manager][Agent] Add metadata parameter (#5475)
add b68bfee80 [INLONG-5489][DataProxy] Optimize message deduplication
logic (#5490)
No new revisions were added by this update.
Summary of changes:
.../dataproxy/config/pojo/MQClusterConfig.java | 4 +-
.../inlong/dataproxy/sink/IdCacheCleaner.java | 78 -----------
.../dataproxy/sink/SimpleMessageTubeSink.java | 110 +++------------
.../org/apache/inlong/dataproxy/sink/TubeSink.java | 152 +++++----------------
.../dataproxy/sink/common/MsgDedupHandler.java | 98 +++++++++++++
5 files changed, 152 insertions(+), 290 deletions(-)
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/IdCacheCleaner.java
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/MsgDedupHandler.java
