From 5645c157c0e58402beb551651358d59bdac36c3b Mon Sep 17 00:00:00 2001 From: Kaijie Chen Date: Thu, 24 Jul 2025 14:22:14 +0800 Subject: [PATCH] [fix](vcg) use "vcg cancel" as cancel message for warm up jobs --- .../java/org/apache/doris/cloud/CacheHotspotManager.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 6f88e6ba0903f4..71d7b5be56b8a2 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 @@ -839,11 +839,15 @@ public void cancel(CancelWarmUpJobCommand stmt) throws DdlException { } public void cancel(long jobId) throws DdlException { + cancel(jobId, "user cancel"); + } + + public void cancel(long jobId, String msg) throws DdlException { CloudWarmUpJob job = cloudWarmUpJobs.get(jobId); if (job == null) { throw new DdlException("job id: " + jobId + " does not exist."); } - if (!job.cancel("user cancel", true)) { + if (!job.cancel(msg, true)) { throw new DdlException("job can not be cancelled. State: " + job.getJobState()); } }