enhance: Set delete scope for LoadSegment streaming data (#30245)

See also #29474

---------

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/30370/head
congqixia 2024-01-30 11:13:02 +08:00 committed by GitHub
parent 0c7a96b48d
commit 7c086a4608
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 0 deletions

View File

@ -617,6 +617,7 @@ func (sd *shardDelegator) loadStreamDelete(ctx context.Context,
SegmentId: info.GetSegmentID(),
PrimaryKeys: storage.ParsePrimaryKeys2IDs(deleteData.Pks),
Timestamps: deleteData.Tss,
Scope: querypb.DataScope_Historical, // only sealed segment need to loadStreamDelete
})
if err != nil {
log.Warn("failed to apply delete when LoadSegment", zap.Error(err))