This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 d6ecea4cd1d [fix](delete) Fix potential delete job stuck util timeout
if exception happend in FE DeleteJob execution (#41672) (#41763)
d6ecea4cd1d is described below
commit d6ecea4cd1d64313f88b2252efca6a5672193a00
Author: Siyang Tang <82279870+tangsiyang2...@users.noreply.github.com>
AuthorDate: Sat Oct 12 22:29:50 2024 +0800
[fix](delete) Fix potential delete job stuck util timeout if exception
happend in FE DeleteJob execution (#41672) (#41763)
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 3e63a5421f7..27469301e17 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
@@ -423,6 +423,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
