test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 19:39:21 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Fix ts loop

Browse Source 
Signed-off-by: neza2017 <yefu.chen@zilliz.com>
This commit is contained in:
neza2017 2021-03-15 15:45:17 +08:00 committed by yefu.chen
parent c1dcc7c88a
commit 9e0fc0b169
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/masterservice/master_service.go
View File

@ -368,12 +368,12 @@ func (c *Core) tsLoop() {
select {
case <-tsoTicker.C:
if err := c.tsoAllocator.UpdateTSO(); err != nil {
log.Warn("failed to update timestamp", zap.String("error", err.Error()))
return
log.Warn("failed to update timestamp: ", zap.Error(err))
continue
}
if err := c.idAllocator.UpdateID(); err != nil {
log.Warn("failed to update id", zap.String("error", err.Error()))
return
log.Warn("failed to update id: ", zap.Error(err))
continue
}
case <-ctx.Done():
// Server is closed and it should return nil.