Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
bobhan1 committed Jul 5, 2024
1 parent 6731c27 commit ae828d4
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -400,8 +400,8 @@ private void finishRealtimePush(AgentTask task, TFinishTaskRequest request) thro
Replica replica = findRelatedReplica(olapTable, partition,
backendId, tabletId, tabletMeta.getIndexId());
if (replica != null) {
pushTask.countDownLatch(backendId, pushTabletId);
deleteJob.addFinishedReplica(partitionId, pushTabletId, replica);
pushTask.countDownLatch(backendId, pushTabletId);
}
}
} else if (pushTask.getPushType() == TPushType.LOAD_V2) {
Expand Down

0 comments on commit ae828d4

Please sign in to comment.