This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 8e77cc94be9 branch-3.0: [fix](cloud) Modify the log level to prevent
too many logs #48524 (#48796)
8e77cc94be9 is described below
commit 8e77cc94be938de06ca9ede074136f10a51bb273
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Mar 10 14:07:52 2025 +0800
branch-3.0: [fix](cloud) Modify the log level to prevent too many logs
#48524 (#48796)
Cherry-picked from #48524
Co-authored-by: deardeng <deng...@selectdb.com>
---
.../main/java/org/apache/doris/catalog/Replica.java | 4 +++-
.../org/apache/doris/cloud/catalog/CloudReplica.java | 4 +++-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 18 +++++++++++++-----
3 files changed, 19 insertions(+), 7 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Replica.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Replica.java
index d248cc40839..22f7128abe3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Replica.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Replica.java
@@ -265,7 +265,9 @@ public class Replica {
try {
return getBackendId();
} catch (UserException e) {
- LOG.warn("getBackendIdWithoutException: ", e);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("getBackendIdWithoutException: ", e);
+ }
return -1;
}
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
index 5bf73e448b6..12f27eae3d0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
@@ -166,7 +166,9 @@ public class CloudReplica extends Replica {
String clusterId = getCloudClusterIdByName(clusterName);
return getBackendIdImpl(clusterId);
} catch (ComputeGroupException e) {
- LOG.warn("failed to get compute group name {}", clusterName, e);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("failed to get compute group name {}", clusterName,
e);
+ }
return -1;
}
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java
index 2bd6d8e0256..6eb5567f7e8 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java
@@ -265,7 +265,9 @@ public class CloudTabletRebalancer extends MasterDaemon {
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
- LOG.info("begin tablets migration from be {} to be {}",
pair.first, pair.second);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("begin tablets migration from be {} to be {}",
pair.first, pair.second);
+ }
migrateTablets(pair.first, pair.second);
}
@@ -577,7 +579,9 @@ public class CloudTabletRebalancer extends MasterDaemon {
try {
beId = ((CloudReplica)
replica).hashReplicaToBe(cluster, true);
} catch (ComputeGroupException e) {
- LOG.warn("failed to hash replica to be {}",
cluster, e);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("failed to hash replica to be
{}", cluster, e);
+ }
beId = -1;
}
}
@@ -1088,7 +1092,9 @@ public class CloudTabletRebalancer extends MasterDaemon {
try {
beId = cloudReplica.getBackendId();
} catch (ComputeGroupException e) {
- LOG.warn("get backend failed cloudReplica {}",
cloudReplica, e);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("get backend failed cloudReplica {}",
cloudReplica, e);
+ }
beId = -1;
}
LOG.error("get null db from replica, tabletId={},
partitionId={}, beId={}",
@@ -1118,8 +1124,10 @@ public class CloudTabletRebalancer extends MasterDaemon {
table.readUnlock();
}
- LOG.info("cloud be migrate tablet {} from srcBe={} to dstBe={},
clusterId={}, clusterName={}",
- tablet.getId(), srcBe, dstBe, clusterId, clusterName);
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("cloud be migrate tablet {} from srcBe={} to
dstBe={}, clusterId={}, clusterName={}",
+ tablet.getId(), srcBe, dstBe, clusterId, clusterName);
+ }
}
long oldSize = infos.size();
infos = batchUpdateCloudReplicaInfoEditlogs(infos);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
