[incubator-inlong] branch master updated: [INLONG-3704][Manager] Change the log level for status report (#3705)

[dockerzhang]

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 497d86e64 [INLONG-3704][Manager] Change the log level for status 
report (#3705)
497d86e64 is described below

commit 497d86e640edf484d8d409adcbda4d465610e5f5
Author: dockerzhang <dockerzh...@apache.org>
AuthorDate: Thu Apr 14 19:20:42 2022 +0800

    [INLONG-3704][Manager] Change the log level for status report (#3705)
---
 .../org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java | 4 +++-
 .../apache/inlong/manager/service/source/SourceSnapshotOperation.java | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
index feb3a1e40..b30199286 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java
@@ -86,7 +86,9 @@ public class AgentServiceImpl implements AgentService {
     @Transactional(rollbackFor = Throwable.class, isolation = 
Isolation.READ_COMMITTED,
             propagation = Propagation.REQUIRES_NEW)
     public void report(TaskRequest request) {
-        LOGGER.info("begin to get agent task: {}", request);
+        if (LOGGER.isDebugEnabled()) {
+            LOGGER.debug("begin to get agent task: {}", request);
+        }
         if (request == null || StringUtils.isBlank(request.getAgentIp())) {
             throw new BusinessException("agent request or agent ip was empty, 
just return");
         }
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
index ae5e6eed8..265650ed2 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperation.java
@@ -128,7 +128,9 @@ public class SourceSnapshotOperation implements 
AutoCloseable {
             // Modify the task status based on the tasks reported in the 
snapshot and the tasks in the cache.
             ConcurrentHashMap<Integer, Integer> idStatusMap = 
agentTaskCache.getIfPresent(agentIp);
             if (MapUtils.isEmpty(idStatusMap)) {
-                LOGGER.info("success report snapshot for ip={}, task status 
cache is null", agentIp);
+                if (LOGGER.isDebugEnabled()) {
+                    LOGGER.debug("success report snapshot for ip={}, task 
status cache is null", agentIp);
+                }
                 return true;
             }
             boolean isInvalid = false;