This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 9d0b957d1f2 branch-3.0: [fix](warmup) fix NPE in getTabletReplicaInfos
#55130 (#55198)
9d0b957d1f2 is described below
commit 9d0b957d1f21c538054b8f3d0e38a591e3e596fc
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 25 16:27:59 2025 +0800
branch-3.0: [fix](warmup) fix NPE in getTabletReplicaInfos #55130 (#55198)
Cherry-picked from #55130
Co-authored-by: Kaijie Chen <[email protected]>
---
.../main/java/org/apache/doris/service/FrontendServiceImpl.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index 49ef6e5e635..f3140d490c1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -2761,6 +2761,14 @@ public class FrontendServiceImpl implements
FrontendService.Iface {
}
clusterId = ((CloudSystemInfoService) Env.getCurrentSystemInfo())
.getCloudClusterIdByName(job.getDstClusterName());
+ if (clusterId == null) {
+ LOG.warn("cluster {} is not found, cannot get primary backend
for warmup job {}",
+ job.getDstClusterName(), request.getWarmUpJobId());
+ result.setTabletReplicaInfos(tabletReplicaInfos);
+ result.setToken(Env.getCurrentEnv().getToken());
+ result.setStatus(new TStatus(TStatusCode.OK));
+ return result;
+ }
}
for (Long tabletId : tabletIds) {
if (DebugPointUtil.isEnable("getTabletReplicaInfos.returnEmpty")) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
