From bfb41c15de313ddc2579ca3f976ee3d8326de938 Mon Sep 17 00:00:00 2001 From: Jibing-Li <64681310+Jibing-Li@users.noreply.github.com> Date: Fri, 14 Jun 2024 09:47:51 +0800 Subject: [PATCH] [fix](statistics)Fix sync analyze job timeout block bug. (#36199) Fix sync analyze job timeout block bug. When a task of a analyze job timeout, it should throw an exception instead of finish silently. --- .../main/java/org/apache/doris/statistics/BaseAnalysisTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/statistics/BaseAnalysisTask.java b/fe/fe-core/src/main/java/org/apache/doris/statistics/BaseAnalysisTask.java index f871e8761a..e04a7274f6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/statistics/BaseAnalysisTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/BaseAnalysisTask.java @@ -208,7 +208,7 @@ public abstract class BaseAnalysisTask { int retriedTimes = 0; while (retriedTimes < StatisticConstants.ANALYZE_TASK_RETRY_TIMES) { if (killed) { - break; + throw new RuntimeException("Task is Killed or Timeout"); } try { doExecute();