This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new e98d08c3599 [fix](delete) Fix potential delete job stuck util timeout
if exception happend in FE DeleteJob execution (#41672) (#43208)
e98d08c3599 is described below
commit e98d08c35998b0e0799be07b43b4b3da2305d01c
Author: Siyang Tang <[email protected]>
AuthorDate: Wed Nov 6 09:56:59 2024 +0800
[fix](delete) Fix potential delete job stuck util timeout if exception
happend in FE DeleteJob execution (#41672) (#43208)
## Proposed changes
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 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: [email protected]
For additional commands, e-mail: [email protected]
