[inlong] branch master updated: [INLONG-7395][Manager] Reduce log in SortSouceService and SortClusterService (#7396)

[healchow]

This is an automated email from the ASF dual-hosted git repository.

healchow 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 730feee34 [INLONG-7395][Manager] Reduce log in SortSouceService and 
SortClusterService (#7396)
730feee34 is described below

commit 730feee341c248327c1c100af3699fb06aeaf046
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Mon Feb 20 20:29:50 2023 +0800

    [INLONG-7395][Manager] Reduce log in SortSouceService and 
SortClusterService (#7396)
---
 .../inlong/manager/service/core/impl/SortClusterServiceImpl.java    | 4 ++--
 .../inlong/manager/service/core/impl/SortSourceServiceImpl.java     | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
index f3541316f..0a6996a87 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
@@ -120,7 +120,7 @@ public class SortClusterServiceImpl implements 
SortClusterService {
         // check if cluster name is valid or not.
         if (StringUtils.isBlank(clusterName)) {
             String errMsg = "Blank cluster name, return nothing";
-            LOGGER.info(errMsg);
+            LOGGER.debug(errMsg);
             return SortClusterResponse.builder()
                     .msg(errMsg)
                     .code(RESPONSE_CODE_REQ_PARAMS_ERROR)
@@ -138,7 +138,7 @@ public class SortClusterServiceImpl implements 
SortClusterService {
         // there is no config, but still return success.
         if (sortClusterConfigMap.get(clusterName) == null) {
             String errMsg = "There is not config for cluster " + clusterName;
-            LOGGER.info(errMsg);
+            LOGGER.debug(errMsg);
             return SortClusterResponse.builder()
                     .msg(errMsg)
                     .code(RESPONSE_CODE_SUCCESS)
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java
index cf699608f..fa669bc0e 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java
@@ -139,7 +139,7 @@ public class SortSourceServiceImpl implements 
SortSourceService {
         // if cluster or task are invalid
         if (StringUtils.isBlank(cluster) || StringUtils.isBlank(task)) {
             String errMsg = "blank cluster name or task name, return nothing";
-            LOGGER.error(errMsg);
+            LOGGER.debug(errMsg);
             return SortSourceConfigResponse.builder()
                     .code(RESPONSE_CODE_REQ_PARAMS_ERROR)
                     .msg(errMsg)
@@ -149,7 +149,7 @@ public class SortSourceServiceImpl implements 
SortSourceService {
         // if there is no config, but still return success
         if (!sortSourceConfigMap.containsKey(cluster) || 
!sortSourceConfigMap.get(cluster).containsKey(task)) {
             String errMsg = String.format("there is no valid source config of 
cluster %s, task %s", cluster, task);
-            LOGGER.error(errMsg);
+            LOGGER.debug(errMsg);
             return SortSourceConfigResponse.builder()
                     .code(RESPONSE_CODE_SUCCESS)
                     .msg(errMsg)
@@ -169,7 +169,7 @@ public class SortSourceServiceImpl implements 
SortSourceService {
         if 
(sortSourceConfigMap.get(cluster).get(task).getCacheZones().isEmpty()) {
             String errMsg = String.format("find empty cache zones of cluster 
%s, task %s, "
                     + "please check the manager log", cluster, task);
-            LOGGER.error(errMsg);
+            LOGGER.debug(errMsg);
             return SortSourceConfigResponse.builder()
                     .code(RESPONSE_CODE_FAIL)
                     .msg(errMsg)