This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new bfb41c15de3 [fix](statistics)Fix sync analyze job timeout block bug.
(#36199)
bfb41c15de3 is described below
commit bfb41c15de313ddc2579ca3f976ee3d8326de938
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Fri Jun 14 09:47:51 2024 +0800
[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.
---
.../src/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 f871e8761a5..e04a7274f69 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();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
