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

fix: add BeginTimestamp and EndTimestamp to insert and upsert messages (#40110)

Browse Source 
- issue: #40109
- caused by: #38656

Signed-off-by: SimFG <bang.fu@zilliz.com>
This commit is contained in:
SimFG 2025-02-22 12:29:53 +08:00 committed by GitHub
parent 8b974c5742
commit ad36347fb3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/proxy/task_insert.go
View File

@ -287,6 +287,8 @@ func (it *insertTask) Execute(ctx context.Context) error {
return err
}
it.insertMsg.CollectionID = collID
it.insertMsg.BeginTimestamp = it.BeginTs()
it.insertMsg.EndTimestamp = it.EndTs()
getCacheDur := tr.RecordSpan()
stream, err := it.chMgr.getOrCreateDmlStream(ctx, collID)

2
internal/proxy/task_upsert.go
View File

@ -436,6 +436,8 @@ func (it *upsertTask) insertExecute(ctx context.Context, msgPack *msgstream.MsgP
return err
}
it.upsertMsg.InsertMsg.CollectionID = collID
it.upsertMsg.InsertMsg.BeginTimestamp = it.BeginTs()
it.upsertMsg.InsertMsg.EndTimestamp = it.EndTs()
log := log.Ctx(ctx).With(
zap.Int64("collectionID", collID))
getCacheDur := tr.RecordSpan()