[fix](delete) Delete should count down latch and clear an agent task when failed

Author: Hastyshell

fe/fe-core/src/main/java/org/apache/doris/master/MasterImpl.java

@@ -342,6 +342,10 @@ private void finishRealtimePush(AgentTask task, TFinishTaskRequest request) thro
         long backendId = pushTask.getBackendId();
         long signature = task.getSignature();
         long transactionId = ((PushTask) task).getTransactionId();
+        long tableId = pushTask.getTableId();
+        long partitionId = pushTask.getPartitionId();
+        long pushIndexId = pushTask.getIndexId();
+        long pushTabletId = pushTask.getTabletId();
 
         if (request.getTaskStatus().getStatusCode() != TStatusCode.OK) {
             if (pushTask.getPushType() == TPushType.DELETE) {
@@ -351,9 +355,12 @@ private void finishRealtimePush(AgentTask task, TFinishTaskRequest request) thro
                 if (request.getTaskStatus().getStatusCode() == TStatusCode.INVALID_ARGUMENT) {
                     pushTask.countDownToZero(request.getTaskStatus().getStatusCode(),
                             task.getBackendId() + ": " + request.getTaskStatus().getErrorMsgs().toString());
-                    AgentTaskQueue.removeTask(backendId, TTaskType.REALTIME_PUSH, signature);
-                    LOG.warn("finish push replica error: {}", request.getTaskStatus().getErrorMsgs().toString());
+                } else {
+                    pushTask.countDownLatch(backendId, pushTabletId);
                 }
+                AgentTaskQueue.removeTask(backendId, TTaskType.REALTIME_PUSH, signature);
+                LOG.warn("finish push replica, signature={}, error: {}",
+                        signature, request.getTaskStatus().getErrorMsgs().toString());
             }
             return;
         }
@@ -367,10 +374,6 @@ private void finishRealtimePush(AgentTask task, TFinishTaskRequest request) thro
             return;
         }
 
-        long tableId = pushTask.getTableId();
-        long partitionId = pushTask.getPartitionId();
-        long pushIndexId = pushTask.getIndexId();
-        long pushTabletId = pushTask.getTabletId();
         // push finish type:
         //                  numOfFinishTabletInfos  tabletId schemaHash
         // Normal:                     1                   /          /