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 71d7b5be56b8a2..7135d401aeb583 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 long createJob(WarmUpClusterCommand stmt) throws AnalysisException { stmt.isForce()); } Map>> 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 8f928d72cb28ab..630c57721ac9c9 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 CloudWarmUpJob(long jobId, String srcClusterName, String dstClusterName, } } + public CloudWarmUpJob(long jobId, String cloudClusterName, + Map>> beToTabletIdBatches, JobType jobType, + List> tables, boolean force) { + this(jobId, null, cloudClusterName, beToTabletIdBatches, jobType); + this.tables = tables; + this.force = force; + } + public void fetchBeToTabletIdBatches() { if (FeConstants.runningUnitTest) { return;