admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: [2.6] Fix data race in replicate stream client (#45347)

Browse Source 
issue: https://github.com/milvus-io/milvus/issues/44123

pr: https://github.com/milvus-io/milvus/pull/45346

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
This commit is contained in:
yihao.dai 2025-11-07 16:43:35 +08:00 committed by GitHub
parent 750af91c5a
commit 0bfb5f6012
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/cdc/replication/replicatestream/replicate_stream_client_impl.go
View File

@ -87,11 +87,11 @@ func NewReplicateStreamClient(ctx context.Context, c cluster.MilvusClient, chann
func (r *replicateStreamClient) startInternal() {
defer func() {
r.metrics.OnClose()
close(r.finishedCh)
log.Info("replicate stream client closed",
zap.String("key", r.channel.Key),
zap.Int64("revision", r.channel.ModRevision))
r.metrics.OnClose()
close(r.finishedCh)
}()
backoff := backoff.NewExponentialBackOff()