This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new dabad7c9509 [fix](statistics)Fix sync analyze job timeout block bug.
(#36217)
dabad7c9509 is described below
commit dabad7c9509030220d82999b6734d8eebcc1c47d
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Mon Jun 17 11:57:45 2024 +0800
[fix](statistics)Fix sync analyze job timeout block bug. (#36217)
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
