This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 4797096485b [fix](warmup) fix show warm up tables (#55192)
4797096485b is described below
commit 4797096485b2617a331fa7b63aa1ca4d910e113b
Author: Kaijie Chen <[email protected]>
AuthorDate: Fri Aug 22 21:40:33 2025 +0800
[fix](warmup) fix show warm up tables (#55192)
### What problem does this PR solve?
Related PR: #51594 #52370
Problem Summary:
Fix show warm up jobs after merging periodic and event driven warmup
feature.
---
.../src/main/java/org/apache/doris/cloud/CacheHotspotManager.java | 4 ++--
.../src/main/java/org/apache/doris/cloud/CloudWarmUpJob.java | 8 ++++++++
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManager.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManager.java
index 71d7b5be56b..7135d401aeb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/CacheHotspotManager.java
@@ -784,8 +784,8 @@ public class CacheHotspotManager extends MasterDaemon {
stmt.isForce());
}
Map<Long, List<List<Long>>> beToTabletIdBatches =
splitBatch(beToWarmUpTablets);
- warmUpJob = new CloudWarmUpJob(jobId, null, stmt.getDstCluster(),
- beToTabletIdBatches, JobType.TABLE);
+ warmUpJob = new CloudWarmUpJob(jobId, stmt.getDstCluster(),
+ beToTabletIdBatches, JobType.TABLE, stmt.getTables(),
stmt.isForce());
} else {
CloudWarmUpJob.Builder builder = new CloudWarmUpJob.Builder()
.setJobId(jobId)
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 8f928d72cb2..630c57721ac 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
@@ -243,6 +243,14 @@ public class CloudWarmUpJob implements Writable {
}
}
+ public CloudWarmUpJob(long jobId, String cloudClusterName,
+ Map<Long, List<List<Long>>> beToTabletIdBatches,
JobType jobType,
+ List<Triple<String, String, String>> tables, boolean
force) {
+ this(jobId, null, cloudClusterName, beToTabletIdBatches, jobType);
+ this.tables = tables;
+ this.force = force;
+ }
+
public void fetchBeToTabletIdBatches() {
if (FeConstants.runningUnitTest) {
return;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
