[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.
This commit is contained in:
Siyang Tang
2024-10-12 22:29:10 +08:00
committed by GitHub
parent 68ae6d025e
commit 87005aa5b2

View File

@ -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();
}