This is an automated email from the ASF dual-hosted git repository.
luchunliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 2fe010987c [INLONG-9598][Agent] Modify comments (#9599)
2fe010987c is described below
commit 2fe010987c9023903d1715d245e60119b2c29887
Author: justinwwhuang <[email protected]>
AuthorDate: Mon Jan 22 14:05:35 2024 +0800
[INLONG-9598][Agent] Modify comments (#9599)
---
.../main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java
index f09de34a1d..01612493eb 100644
---
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java
+++
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java
@@ -64,7 +64,7 @@ public abstract class AbstractSink implements Sink {
protected String sourceName;
protected String jobInstanceId;
protected int batchFlushInterval;
- // key is stream id, value is a batch of messages belong to the same
stream id
+ // key is stream id, value is a batch of messages belongs to the same
stream id
protected ConcurrentHashMap<String, PackProxyMessage> cache;
@Override