yihao.dai
yihao.dai
> reproduced in `master-20240709-eeb03a0d-amd64` datanode chaos test > > failed job: https://qa-jenkins.milvus.io/blue/organizations/jenkins/chaos-test-kafka-cron/detail/chaos-test-kafka-cron/15588/pipeline > > log:[artifacts-datanode-pod-kill-15588-server-logs.tar.gz](https://github.com/user-attachments/files/16154356/artifacts-datanode-pod-kill-15588-server-logs.tar.gz) dispatcher merged by mistake, the insert data consumed was incorrectly skipped: 
/assign @zhuwenxing should be fixed
Same as https://github.com/milvus-io/milvus/issues/45301:
This PR (https://github.com/milvus-io/milvus/pull/34278) accelerates the subscription speed of the dispatcher. However, the subscription becomes too fast for the dispatcher to merge in time, causing the DataNode OOM. **Test with PR...
PRs https://github.com/milvus-io/milvus/pull/40596 and https://github.com/milvus-io/milvus/pull/40854 should be highly beneficial for this case. Please help to verify. @zhuwenxing