This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 89aab32e4b3 branch-4.0: [fix](cloud) Add cluster name for routine load
err msg #59099 (#59231)
89aab32e4b3 is described below
commit 89aab32e4b3243252206a242d18a71b58bce6518
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 23 16:52:15 2025 +0800
branch-4.0: [fix](cloud) Add cluster name for routine load err msg #59099
(#59231)
Cherry-picked from #59099
Co-authored-by: deardeng <[email protected]>
---
.../src/main/java/org/apache/doris/clone/TabletScheduler.java | 4 ++++
.../org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java | 5 ++++-
.../java/org/apache/doris/cloud/system/CloudSystemInfoService.java | 6 ++++++
.../java/org/apache/doris/load/routineload/RoutineLoadManager.java | 2 +-
4 files changed, 15 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
index c9cbfc7cf72..a15830efe01 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
@@ -351,6 +351,7 @@ public class TabletScheduler extends MasterDaemon {
*/
@Override
public void runAfterCatalogReady() {
+ long start = System.currentTimeMillis();
if (!updateWorkingSlots()) {
return;
}
@@ -361,6 +362,9 @@ public class TabletScheduler extends MasterDaemon {
schedulePendingTablets();
stat.counterTabletScheduleRound.incrementAndGet();
+ // Add a log message to indicate that this thread is operating
normally.
+ LOG.info("finished to tablet scheduler. cost: {} ms",
+ System.currentTimeMillis() - start);
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
index 40feb8b787b..794a197ba82 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudInstanceStatusChecker.java
@@ -58,6 +58,7 @@ public class CloudInstanceStatusChecker extends MasterDaemon {
@Override
protected void runAfterCatalogReady() {
try {
+ long start = System.currentTimeMillis();
Cloud.GetInstanceResponse response =
cloudSystemInfoService.getCloudInstance();
if (!isResponseValid(response)) {
return;
@@ -67,7 +68,9 @@ public class CloudInstanceStatusChecker extends MasterDaemon {
cloudSystemInfoService.setInstanceStatus(instance.getStatus());
syncStorageVault(instance);
processVirtualClusters(instance.getClustersList());
-
+ // Add a log message to indicate that this thread is operating
normally.
+ LOG.info("finished to cloud instance checker. cost: {} ms",
+ System.currentTimeMillis() - start);
} catch (Exception e) {
LOG.warn("get instance from ms exception", e);
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
index 72e52a34003..9708d49686f 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
@@ -820,6 +820,9 @@ public class CloudSystemInfoService extends
SystemInfoService {
public List<Backend> getBackendsByClusterName(final String clusterName) {
String physicalClusterName = getPhysicalCluster(clusterName);
String clusterId = clusterNameToId.getOrDefault(physicalClusterName,
"");
+ LOG.debug("getBackendsByClusterName clusterName={} "
+ + "physicalClusterName={} clusterId={} clusterNameToId={}
clusterIdToBackend={}",
+ clusterName, physicalClusterName, clusterId, clusterNameToId,
clusterIdToBackend);
if (clusterId.isEmpty()) {
return new ArrayList<>();
}
@@ -831,6 +834,9 @@ public class CloudSystemInfoService extends
SystemInfoService {
String clusterName = getClusterNameByClusterId(clusterId);
String physicalClusterName = getPhysicalCluster(clusterName);
String physicalClusterId =
getCloudClusterIdByName(physicalClusterName);
+ LOG.debug("getBackendsByClusterId clusterName={} "
+ + "physicalClusterName={} clusterId={} clusterNameToId={}
clusterIdToBackend={}",
+ clusterName, physicalClusterName, clusterId, clusterNameToId,
clusterIdToBackend);
// copy a new List
return new
ArrayList<>(clusterIdToBackend.getOrDefault(physicalClusterId, new
ArrayList<>()));
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java
index fcedacec8ad..bcb62cca8a0 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java
@@ -500,7 +500,7 @@ public class RoutineLoadManager implements Writable {
if (availableBeIds.isEmpty()) {
RoutineLoadJob job = getJob(jobId);
if (job != null) {
- String msg = "no available BE found for job " + jobId
+ String msg = "no available BE found for job " + jobId + ",
cluster Name {}, " + job.getCloudCluster()
+ "please check the BE status and user's cluster or
tags";
job.updateState(RoutineLoadJob.JobState.PAUSED,
new ErrorReason(InternalErrorCode.INTERNAL_ERR, msg),
false /* not replay */);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
