Skip to content

M
milvus

milvus / milvus
11 个月 前同步成功

通知 261
Star 22476
Fork 2472
M
milvus

体验新版 GitCode，发现更多精彩内容 >>

未验证 提交 8ff1a2c4 编写于 作者: X xige-16 提交者： GitHub
浏览文件
操作

Print expr when proxy receive qyery req (#17662) 

Signed-off-by: Nxige-16 <xi.ge@zilliz.com>
上级 216e2f80
隐藏空白更改
内联 并排
Showing with 9 addition and 11 deletion
internal/proxy/impl.go
浏览文件 @ 8ff1a2c4
......@@ -2678,7 +2678,11 @@ func (node *Proxy) Query(ctx context.Context, request *milvuspb.QueryRequest) (*
zap.String("role", typeutil.ProxyRole),
zap.String("db", request.DbName),
zap.String("collection", request.CollectionName),
zap.Any("partitions", request.PartitionNames))
zap.Strings("partitions", request.PartitionNames),
zap.String("expr", request.Expr),
zap.Strings("OutputFields", request.OutputFields),
zap.Uint64("travel_timestamp", request.TravelTimestamp),
zap.Uint64("guarantee_timestamp", request.GuaranteeTimestamp))
if err := node.sched.dqQueue.Enqueue(qt); err != nil {
log.Warn(
......@@ -2706,12 +2710,10 @@ func (node *Proxy) Query(ctx context.Context, request *milvuspb.QueryRequest) (*
rpcEnqueued(method),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.Int64("MsgID", qt.ID()),
zap.Uint64("BeginTs", qt.BeginTs()),
zap.Uint64("EndTs", qt.EndTs()),
zap.Int64("msgID", qt.ID()),
zap.String("db", request.DbName),
zap.String("collection", request.CollectionName),
zap.Any("partitions", request.PartitionNames))
zap.Strings("partitions", request.PartitionNames))
if err := qt.WaitToFinish(); err != nil {
log.Warn(
......@@ -2719,9 +2721,7 @@ func (node *Proxy) Query(ctx context.Context, request *milvuspb.QueryRequest) (*
zap.Error(err),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.Int64("MsgID", qt.ID()),
zap.Uint64("BeginTs", qt.BeginTs()),
zap.Uint64("EndTs", qt.EndTs()),
zap.Int64("msgID", qt.ID()),
zap.String("db", request.DbName),
zap.String("collection", request.CollectionName),
zap.Any("partitions", request.PartitionNames))
......@@ -2743,9 +2743,7 @@ func (node *Proxy) Query(ctx context.Context, request *milvuspb.QueryRequest) (*
rpcDone(method),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.Int64("MsgID", qt.ID()),
zap.Uint64("BeginTs", qt.BeginTs()),
zap.Uint64("EndTs", qt.EndTs()),
zap.Int64("msgID", qt.ID()),
zap.String("db", request.DbName),
zap.String("collection", request.CollectionName),
zap.Any("partitions", request.PartitionNames))
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或