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 3e63a5421f798f..27469301e17615 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 @@ -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(); }