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 e042e0158e1 branch-3.1: [fix](warmup) fix NPE in getTabletReplicaInfos
#55130 (#55199)
e042e0158e1 is described below
commit e042e0158e1b8b01a0f6b2453de983ff43a60233
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 25 15:02:45 2025 +0800
branch-3.1: [fix](warmup) fix NPE in getTabletReplicaInfos #55130 (#55199)
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 264801586db..67882a209a8 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
@@ -2876,6 +2876,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]
