diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java index 407c292074b46f..684e86aa160d68 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/GroupCommitManager.java @@ -217,7 +217,7 @@ public Backend selectBackendForGroupCommit(long tableId, ConnectContext context) try { // Master FE will select BE by itself. return Env.getCurrentSystemInfo() - .getBackend(selectBackendForGroupCommitInternal(tableId, clusterName)); + .getBackend(selectBackendForGroupCommitInternal(tableId, clusterName)); } catch (Exception e) { LOG.warn("get backend failed, tableId: {}, exception", tableId, e); throw new LoadException(e.getMessage()); @@ -263,8 +263,10 @@ public long selectBackendForGroupCommitInternal(long tableId, String cluster) private long selectBackendForCloudGroupCommitInternal(long tableId, String cluster) throws DdlException, LoadException { - LOG.debug("cloud group commit select be info, tableToBeMap {}, tablePressureMap {}", - tableToBeMap.toString(), tableToPressureMap.toString()); + if (LOG.isDebugEnabled()) { + LOG.debug("cloud group commit select be info, tableToBeMap {}, tablePressureMap {}", + tableToBeMap.toString(), tableToPressureMap.toString()); + } if (Strings.isNullOrEmpty(cluster)) { ErrorReport.reportDdlException(ErrorCode.ERR_NO_CLUSTER_ERROR); } @@ -293,8 +295,10 @@ private long selectBackendForCloudGroupCommitInternal(long tableId, String clust } private long selectBackendForLocalGroupCommitInternal(long tableId) throws LoadException { - LOG.debug("group commit select be info, tableToBeMap {}, tablePressureMap {}", tableToBeMap.toString(), - tableToPressureMap.toString()); + if (LOG.isDebugEnabled()) { + LOG.debug("group commit select be info, tableToBeMap {}, tablePressureMap {}", tableToBeMap.toString(), + tableToPressureMap.toString()); + } Long cachedBackendId = getCachedBackend(null, tableId); if (cachedBackendId != null) { return cachedBackendId; @@ -399,8 +403,10 @@ public void updateLoadData(long tableId, long receiveData) { private void updateLoadDataInternal(long tableId, long receiveData) { if (tableToPressureMap.containsKey(tableId)) { tableToPressureMap.get(tableId).add(receiveData); - LOG.info("Update load data for table {}, receiveData {}, tablePressureMap {}", tableId, receiveData, - tableToPressureMap.toString()); + if (LOG.isDebugEnabled()) { + LOG.debug("Update load data for table {}, receiveData {}, tablePressureMap {}", tableId, receiveData, + tableToPressureMap.toString()); + } } else if (LOG.isDebugEnabled()) { LOG.debug("can not find table id {}", tableId); }