You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by do...@apache.org on 2022/08/12 02:24:16 UTC

[inlong] branch master updated (5c6690cfe -> b68bfee80)

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