milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix not fill timestamp when use collection created ts (#22629) 

Signed-off-by: yah01 <yang.cen@zilliz.com>
pull/22684/head
yah01 2023-03-08 18:53:51 +08:00 committed by GitHub
parent ae09122cf0
commit efdc77bce6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datacoord/handler.go
View File

@ -280,7 +280,11 @@ func (h *ServerHandler) GetChannelSeekPosition(channel *channel, partitionID Uni
} }
func getCollectionStartPosition(channel string, collectionInfo *collectionInfo) *msgpb.MsgPosition { func getCollectionStartPosition(channel string, collectionInfo *collectionInfo) *msgpb.MsgPosition {
return toMsgPosition(channel, collectionInfo.StartPositions) position := toMsgPosition(channel, collectionInfo.StartPositions)
if position != nil {
position.Timestamp = collectionInfo.CreatedAt
}
return position
} }
func toMsgPosition(channel string, startPositions []*commonpb.KeyDataPair) *msgpb.MsgPosition { func toMsgPosition(channel string, startPositions []*commonpb.KeyDataPair) *msgpb.MsgPosition {

1
internal/datacoord/meta.go
View File

@ -76,6 +76,7 @@ type collectionInfo struct {
Partitions []int64 Partitions []int64
StartPositions []*commonpb.KeyDataPair StartPositions []*commonpb.KeyDataPair
Properties map[string]string Properties map[string]string
CreatedAt Timestamp
} }
// NewMeta creates meta from provided `kv.TxnKV` // NewMeta creates meta from provided `kv.TxnKV`

1
internal/datacoord/server.go
View File

@ -1007,6 +1007,7 @@ func (s *Server) loadCollectionFromRootCoord(ctx context.Context, collectionID i
Partitions: presp.PartitionIDs, Partitions: presp.PartitionIDs,
StartPositions: resp.GetStartPositions(), StartPositions: resp.GetStartPositions(),
Properties: properties, Properties: properties,
CreatedAt: resp.GetCreatedTimestamp(),
} }
s.meta.AddCollection(collInfo) s.meta.AddCollection(collInfo)
return nil return nil