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)
