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/03/13 12:44:40 UTC
[incubator-inlong] branch master updated: [INLONG-3099][Agent] Duplicate send message when agent receive data (#3103)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 4b148df [INLONG-3099][Agent] Duplicate send message when agent receive data (#3103)
4b148df is described below
commit 4b148dfa3c79e26fed1da5838b2aa44bb952baa3
Author: ziruipeng <zp...@connect.ust.hk>
AuthorDate: Sun Mar 13 20:44:33 2022 +0800
[INLONG-3099][Agent] Duplicate send message when agent receive data (#3103)
---
.../java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
index 1cb7d02..8c0944f 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
@@ -101,7 +101,6 @@ public class PackProxyMessage {
} catch (Exception ex) {
LOGGER.error("exception caught", ex);
}
- messageQueue.offer(message);
}
/**