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/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 7d460623a6 [INLONG-9704][Agent] Modify the default value of memory
control semaphores to adapt to businesses with large amounts of data (#9705)
7d460623a6 is described below
commit 7d460623a64f2a634aa0eb981b8ed427ca9d949d
Author: justinwwhuang <[email protected]>
AuthorDate: Tue Feb 20 16:04:53 2024 +0800
[INLONG-9704][Agent] Modify the default value of memory control semaphores
to adapt to businesses with large amounts of data (#9705)
---
.../java/org/apache/inlong/agent/constant/FetcherConstants.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/FetcherConstants.java
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/FetcherConstants.java
index c336bce2cd..b925cf5732 100644
---
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/FetcherConstants.java
+++
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/FetcherConstants.java
@@ -76,11 +76,8 @@ public class FetcherConstants {
public static final int DEFAULT_AGENT_GLOBAL_READER_SOURCE_PERMIT = 16 *
1000 * 1000;
public static final String AGENT_GLOBAL_READER_QUEUE_PERMIT =
"agent.global.reader.queue.permit";
- public static final int DEFAULT_AGENT_GLOBAL_READER_QUEUE_PERMIT = 16 *
1000 * 1000;
-
- public static final String AGENT_GLOBAL_CHANNEL_PERMIT =
"agent.global.channel.permit";
- public static final int DEFAULT_AGENT_GLOBAL_CHANNEL_PERMIT = 16 * 1000 *
1000;
+ public static final int DEFAULT_AGENT_GLOBAL_READER_QUEUE_PERMIT = 128 *
1000 * 1000;
public static final String AGENT_GLOBAL_WRITER_PERMIT =
"agent.global.writer.permit";
- public static final int DEFAULT_AGENT_GLOBAL_WRITER_PERMIT = 96 * 1000 *
1000;
+ public static final int DEFAULT_AGENT_GLOBAL_WRITER_PERMIT = 128 * 1000 *
1000;
}