Skip to content

Commit

Permalink
[fix](delete) Fix potential delete job stuck util timeout if exceptio…
Browse files Browse the repository at this point in the history
…n happend in FE DeleteJob execution (#41672)

## Proposed changes

Fail task should also count down for the count down latch to prevent job
stuck.
  • Loading branch information
TangSiyang2001 committed Oct 12, 2024
1 parent 9a9eaa7 commit 0bf9647
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -423,6 +423,9 @@ private void finishRealtimePush(AgentTask task, TFinishTaskRequest request) thro
} 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();
}
Expand Down

0 comments on commit 0bf9647

Please sign in to comment.