This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 3a85f78cb59 [fix](delete) Fix potential delete job stuck util timeout
if exception happend in FE DeleteJob execution (#41672)
3a85f78cb59 is described below
commit 3a85f78cb59cfc72413e384514a94712f9883073
Author: Siyang Tang <82279870+tangsiyang2...@users.noreply.github.com>
AuthorDate: Thu Oct 10 22:20:47 2024 +0800
[fix](delete) Fix potential delete job stuck util timeout if exception
happend in FE DeleteJob execution (#41672)
## Proposed changes
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 b427f4b62ba..35b6a230b24 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
@@ -439,6 +439,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
