test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 02:48:45 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

fix: panic in timetick_sender (#35451)

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

Signed-off-by: fengjun2016 <jornfeng@gmail.com>
This commit is contained in:
CharlesFeng 2024-08-14 10:10:53 +08:00 committed by GitHub
parent 6f3fcdc810
commit a690e6e004
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/flushcommon/util/timetick_sender.go
View File

@ -164,9 +164,10 @@ func (m *TimeTickSender) cleanStatesCache(lastSentTss map[string]uint64) {
delete(m.statsCache[channelName].segStats, segmentID)
}
}
}
if len(m.statsCache[channelName].segStats) == 0 {
delete(m.statsCache, channelName)
if len(m.statsCache[channelName].segStats) == 0 {
delete(m.statsCache, channelName)
}
}
}
log.RatedDebug(30, "TimeTickSender stats", zap.Any("lastSentTss", lastSentTss), zap.Int("sizeBeforeClean", sizeBeforeClean), zap.Int("sizeAfterClean", len(m.statsCache)))