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 c96d76803e5 branch-3.1: [fix](warmup): refresh BE list on every job
execution #54963 (#55208)
c96d76803e5 is described below
commit c96d76803e5ad2253eb5ae9c4e7626ffb8e45fcb
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 25 17:16:12 2025 +0800
branch-3.1: [fix](warmup): refresh BE list on every job execution #54963
(#55208)
Cherry-picked from #54963
Co-authored-by: Kaijie Chen <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java
index aacec3f3f99..6a99b10f82e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java
@@ -220,6 +220,7 @@ public class CloudWarmUpJob implements Writable {
String clusterName = isEventDriven() ? srcClusterName : dstClusterName;
List<Backend> backends = ((CloudSystemInfoService)
Env.getCurrentSystemInfo())
.getBackendsByClusterName(clusterName);
+ this.beToThriftAddress = new HashMap<>();
for (Backend backend : backends) {
beToThriftAddress.put(backend.getId(), backend.getHost() + ":" +
backend.getBePort());
}
@@ -597,6 +598,10 @@ public class CloudWarmUpJob implements Writable {
this.setJobDone = false;
this.lastBatchId = -1;
this.startTimeMs = System.currentTimeMillis();
+ // reset clients to ensure we have the latest BE info
+ this.beToThriftAddress = null;
+ this.beToClient = null;
+ this.beToAddr = null;
MetricRepo.updateClusterWarmUpJobLatestStartTime(String.valueOf(jobId),
srcClusterName,
dstClusterName, startTimeMs);
this.fetchBeToTabletIdBatches();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
