This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 87005aa5b26 [fix](delete) Fix potential delete job stuck util timeout
if exception happend in FE DeleteJob execution (#41672) (#41765)
87005aa5b26 is described below
commit 87005aa5b26a79b694fd85ff35eee17151d36ccd
Author: Siyang Tang <82279870+tangsiyang2...@users.noreply.github.com>
AuthorDate: Sat Oct 12 22:29:10 2024 +0800
[fix](delete) Fix potential delete job stuck util timeout if exception
happend in FE DeleteJob execution (#41672) (#41765)
pick: #41672
Fail task should also count down for the count down latch to prevent job
stuck.
---
fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java
b/fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java
index 4870b3a5820..a1acd72974d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java
@@ -433,6 +433,9 @@ public class MasterImpl {
} catch (MetaNotFoundException e) {
AgentTaskQueue.removeTask(backendId, TTaskType.REALTIME_PUSH,
signature);
LOG.warn("finish push replica error", e);
+ if (pushTask.getPushType() == TPushType.DELETE) {
+ pushTask.countDownLatch(backendId, pushTabletId);
+ }
} finally {
olapTable.writeUnlock();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
