diff --git a/internal/datanode/flow_graph_delete_node.go b/internal/datanode/flow_graph_delete_node.go index 46bf0a218ee2546c793f8ac3990551a83d7bb7dd..db148564abe1258db41fbcf21cbcee6c42394634 100644 --- a/internal/datanode/flow_graph_delete_node.go +++ b/internal/datanode/flow_graph_delete_node.go @@ -115,7 +115,7 @@ func (dn *deleteNode) Operate(in []Msg) []Msg { // process flush messages if len(fgMsg.segmentsToSync) > 0 { - log.Debug("DeleteNode receives flush message", + log.Info("DeleteNode receives flush message", zap.Int64s("segIDs", fgMsg.segmentsToSync), zap.String("vChannelName", dn.channelName), zap.Time("posTime", tsoutil.PhysicalTime(fgMsg.endPositions[0].Timestamp))) diff --git a/internal/proxy/default_limit_reducer.go b/internal/proxy/default_limit_reducer.go index 9e72b12fe033beaf3a8622f32502da9cd4a7c459..8987164afeeca2cc0639808e0bca5821ac4885d5 100644 --- a/internal/proxy/default_limit_reducer.go +++ b/internal/proxy/default_limit_reducer.go @@ -7,10 +7,8 @@ import ( "github.com/milvus-io/milvus-proto/go-api/milvuspb" "github.com/milvus-io/milvus-proto/go-api/schemapb" "github.com/milvus-io/milvus/internal/common" - "github.com/milvus-io/milvus/internal/log" "github.com/milvus-io/milvus/internal/proto/internalpb" "github.com/milvus-io/milvus/internal/util/typeutil" - "go.uber.org/zap" ) type defaultLimitReducer struct { @@ -36,7 +34,6 @@ func (r *defaultLimitReducer) Reduce(results []*internalpb.RetrieveResults) (*mi func (r *defaultLimitReducer) afterReduce(result *milvuspb.QueryResults) error { collectionName := r.collectionName - ctx := r.ctx schema := r.schema outputFieldsID := r.req.GetOutputFieldsId() @@ -47,8 +44,6 @@ func (r *defaultLimitReducer) afterReduce(result *milvuspb.QueryResults) error { ErrorCode: commonpb.ErrorCode_Success, } } else { - log.Ctx(ctx).Warn("Query result is nil", - zap.Any("requestType", "query")) result.Status = &commonpb.Status{ ErrorCode: commonpb.ErrorCode_EmptyCollection, Reason: "empty collection", // TODO