admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-28 14:35:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: lost broadcasting persisted before making message broadcast (#46328)

Browse Source 
issue: #43897

Signed-off-by: chyezh <chyezh@outlook.com>
This commit is contained in:
Zhen Ye 2025-12-15 13:59:15 +08:00 committed by GitHub
parent f6f716bcfd
commit 9ce5f08cc7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/streamingcoord/server/broadcaster/broadcast_task.go
View File

@ -28,7 +28,7 @@ func newBroadcastTaskFromProto(proto *streamingpb.BroadcastTask, metrics *broadc
taskMetricsGuard: m,
msg: msg,
task: proto,
dirty: true, // the task is recovered from the recovery info, so it's persisted.
dirty: false, // the task is recovered from the recovery info, so it's persisted.
ackCallbackScheduler: ackCallbackScheduler,
done: make(chan struct{}),
allAcked: make(chan struct{}),
@ -76,7 +76,7 @@ func newBroadcastTaskFromBroadcastMessage(msg message.BroadcastMutableMessage, m
AckedVchannelBitmap: make([]byte, len(header.VChannels)),
AckedCheckpoints: make([]*streamingpb.AckedCheckpoint, len(header.VChannels)),
},
dirty: false,
dirty: true,
ackCallbackScheduler: ackCallbackScheduler,
done: make(chan struct{}),
allAcked: make(chan struct{}),