This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 061448f3a8b branch-3.1: [Enhancement](Log) change some logs from info
to debug #55808 (#55841)
061448f3a8b is described below
commit 061448f3a8bd0b6f9792a84c9237fa0da19dd772
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Sep 10 16:53:43 2025 +0800
branch-3.1: [Enhancement](Log) change some logs from info to debug #55808
(#55841)
Cherry-picked from #55808
Co-authored-by: abmdocrt <[email protected]>
---
.../org/apache/doris/load/GroupCommitManager.java | 20 +++++++++++++-------
1 file changed, 13 insertions(+), 7 deletions(-)
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 407c292074b..684e86aa160 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 class GroupCommitManager {
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 class GroupCommitManager {
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 @@ public class GroupCommitManager {
}
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 class GroupCommitManager {
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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
