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/04/13 03:33:20 UTC
[incubator-inlong] branch master updated: [INLONG-3653][Agent] Avoid printing a lot of logs (#3654)
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 42ae92cf9 [INLONG-3653][Agent] Avoid printing a lot of logs (#3654)
42ae92cf9 is described below
commit 42ae92cf97e6b01123fac381b30b58dff7c98459
Author: baomingyu <ba...@163.com>
AuthorDate: Wed Apr 13 11:33:14 2022 +0800
[INLONG-3653][Agent] Avoid printing a lot of logs (#3654)
---
.../src/main/java/org/apache/inlong/agent/utils/HttpManager.java | 4 +++-
.../src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java | 4 +++-
.../java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java | 4 +++-
3 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
index 86e95a959..f31e8a512 100644
--- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
+++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java
@@ -84,7 +84,9 @@ public class HttpManager {
String returnStr = EntityUtils.toString(response.getEntity());
if (returnStr != null && !returnStr.isEmpty()
&& response.getStatusLine().getStatusCode() == 200) {
- LOGGER.info("request url {}, dto: {}, return str {}", url, dto, returnStr);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("request url {}, dto: {}, return str {}", url, dto, returnStr);
+ }
return returnStr;
}
} catch (Exception e) {
diff --git a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
index 2160a3fcd..c3727eddd 100644
--- a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
+++ b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
@@ -129,7 +129,9 @@ public class HeartbeatManager extends AbstractDaemon {
try {
TaskSnapshotRequest taskSnapshotRequest = getHeartBeat();
httpManager.doSentPost(reportSnapshotUrl, taskSnapshotRequest);
- LOGGER.info(" {} report to manager", taskSnapshotRequest);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug(" {} report to manager", taskSnapshotRequest);
+ }
int heartbeatInterval = conf.getInt(AGENT_HEARTBEAT_INTERVAL,
DEFAULT_AGENT_HEARTBEAT_INTERVAL);
TimeUnit.SECONDS.sleep(heartbeatInterval);
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
index 6ab1dfad1..27fb56495 100755
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
@@ -257,7 +257,9 @@ public class ManagerFetcher extends AbstractDaemon implements ProfileFetcher {
}
private void dealWithSqlTaskResult(DbCollectorTaskResult taskResult) {
- LOGGER.info("deal with sql task result {}", taskResult);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("deal with sql task result {}", taskResult);
+ }
if (!taskResult.getVersion().equals(VERSION)) {
LOGGER.error("invalid version {} != {}", taskResult.getVersion(), VERSION);
return;