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 authored Oct 10, 2024
1 parent a9caf05 commit 3a85f78
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -439,6 +439,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 3a85f78

Please sign in to comment.