admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-04 11:18:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Close tSafe update log print (#12992)

Browse Source 
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
This commit is contained in:
bigsheeper 2021-12-09 14:33:44 +08:00 committed by GitHub
parent 772771bd85
commit 57707e0d11
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/querynode/flow_graph_service_time_node.go
View File

@ -19,11 +19,11 @@ package querynode
import (
"context"
"go.uber.org/zap"
"github.com/milvus-io/milvus/internal/log"
"github.com/milvus-io/milvus/internal/msgstream"
"github.com/milvus-io/milvus/internal/util/flowgraph"
"github.com/milvus-io/milvus/internal/util/tsoutil"
"go.uber.org/zap"
)
type serviceTimeNode struct {
@ -74,14 +74,14 @@ func (stNode *serviceTimeNode) Operate(in []flowgraph.Msg) []flowgraph.Msg {
if err != nil {
log.Warn(err.Error())
}
p, _ := tsoutil.ParseTS(serviceTimeMsg.timeRange.timestampMax)
log.Debug("update tSafe:",
zap.Any("collectionID", stNode.collectionID),
zap.Any("tSafe", serviceTimeMsg.timeRange.timestampMax),
zap.Any("tSafe_p", p),
zap.Any("id", id),
zap.Any("channel", stNode.vChannel),
)
//p, _ := tsoutil.ParseTS(serviceTimeMsg.timeRange.timestampMax)
//log.Debug("update tSafe:",
// zap.Any("collectionID", stNode.collectionID),
// zap.Any("tSafe", serviceTimeMsg.timeRange.timestampMax),
// zap.Any("tSafe_p", p),
// zap.Any("id", id),
// zap.Any("channel", stNode.vChannel),
//)
//if err := stNode.sendTimeTick(serviceTimeMsg.timeRange.timestampMax); err != nil {
// log.Warn("Error: send time tick into pulsar channel failed", zap.Error(err))

12
internal/querynode/query_collection.go
View File

@ -270,12 +270,12 @@ func (q *queryCollection) waitNewTSafe() (Timestamp, error) {
t = ts
}
}
p, _ := tsoutil.ParseTS(t)
log.Debug("waitNewTSafe",
zap.Any("collectionID", q.collectionID),
zap.Any("tSafe", t),
zap.Any("tSafe_p", p),
)
//p, _ := tsoutil.ParseTS(t)
//log.Debug("waitNewTSafe",
// zap.Any("collectionID", q.collectionID),
// zap.Any("tSafe", t),
// zap.Any("tSafe_p", p),
//)
return t, nil
}