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 b58c87d88a07e9..ed51961151e334 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 @@ -785,8 +785,8 @@ public long createJob(WarmUpClusterStmt stmt) throws AnalysisException { stmt.isForce()); } Map>> beToTabletIdBatches = splitBatch(beToWarmUpTablets); - warmUpJob = new CloudWarmUpJob(jobId, null, stmt.getDstClusterName(), - beToTabletIdBatches, JobType.TABLE); + warmUpJob = new CloudWarmUpJob(jobId, stmt.getDstClusterName(), + beToTabletIdBatches, JobType.TABLE, stmt.getTables(), stmt.isForce()); } else { CloudWarmUpJob.Builder builder = new CloudWarmUpJob.Builder() .setJobId(jobId)