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 2023/03/19 07:06:44 UTC
[inlong] branch master updated: [INLONG-7512][DataProxy] Change the log level to DEBUG to avoid generating a lot of log files. (#7634)
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 5e3f8496a [INLONG-7512][DataProxy] Change the log level to DEBUG to avoid generating a lot of log files. (#7634)
5e3f8496a is described below
commit 5e3f8496ae090c3ddee544ba86c2f840795c85f5
Author: hongyu guo <10...@users.noreply.github.com>
AuthorDate: Sun Mar 19 15:06:37 2023 +0800
[INLONG-7512][DataProxy] Change the log level to DEBUG to avoid generating a lot of log files. (#7634)
---
.../java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java
index 4c1edf190..d5fae2e04 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java
@@ -156,7 +156,7 @@ public class BatchPackManager {
if (!needOutputOvertimeData.getAndSet(false)) {
return;
}
- LOG.info("start to outputOvertimeData profileCacheSize:{},dispatchQueueSize:{}",
+ LOG.debug("start to outputOvertimeData profileCacheSize:{},dispatchQueueSize:{}",
profileCache.size(), dispatchQueue.size());
long currentTime = System.currentTimeMillis();
long createThreshold = currentTime - dispatchTimeout;
@@ -179,7 +179,7 @@ public class BatchPackManager {
outCounter.addAndGet(dispatchProfile.getCount());
}
});
- LOG.info("end to outputOvertimeData profileCacheSize:{},dispatchQueueSize:{},eventCount:{},"
+ LOG.debug("end to outputOvertimeData profileCacheSize:{},dispatchQueueSize:{},eventCount:{},"
+ "inCounter:{},outCounter:{}",
profileCache.size(), dispatchQueue.size(), eventCount,
inCounter.getAndSet(0), outCounter.getAndSet(0));