diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go
index 1340c064a2..566510101e 100644
--- a/internal/querynode/impl.go
+++ b/internal/querynode/impl.go
@@ -930,7 +930,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
 	}
 
 	msgID := req.GetReq().GetBase().GetMsgID()
-	log.Ctx(ctx).Debug("Received QueryRequest",
+	log.Ctx(ctx).Debug("queryWithDmlChannel receives query request",
 		zap.Int64("msgID", msgID),
 		zap.Bool("fromShardLeader", req.GetFromShardLeader()),
 		zap.String("vChannel", dmlChannel),
@@ -950,7 +950,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
 		return failRet, nil
 	}
 
-	log.Ctx(ctx).Debug("start do query",
+	log.Ctx(ctx).Debug("queryWithDmlChannel starts do query",
 		zap.Int64("msgID", msgID),
 		zap.Bool("fromShardLeader", req.GetFromShardLeader()),
 		zap.String("vChannel", dmlChannel),
@@ -1055,6 +1055,7 @@ func (node *QueryNode) queryWithDmlChannel(ctx context.Context, req *querypb.Que
 // Query performs replica query tasks.
 func (node *QueryNode) Query(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error) {
 	log.Ctx(ctx).Debug("Received QueryRequest", zap.Int64("msgID", req.GetReq().GetBase().GetMsgID()),
+		zap.Bool("fromShardleader", req.GetFromShardLeader()),
 		zap.Strings("vChannels", req.GetDmlChannels()),
 		zap.Int64s("segmentIDs", req.GetSegmentIDs()),
 		zap.Uint64("guaranteeTimestamp", req.Req.GetGuaranteeTimestamp()),
diff --git a/internal/querynode/result.go b/internal/querynode/result.go
index da08167ba6..7827476817 100644
--- a/internal/querynode/result.go
+++ b/internal/querynode/result.go
@@ -253,7 +253,7 @@ func encodeSearchResultData(searchResultData *schemapb.SearchResultData, nq int6
 }
 
 func mergeInternalRetrieveResult(ctx context.Context, retrieveResults []*internalpb.RetrieveResults, limit int64) (*internalpb.RetrieveResults, error) {
-	log.Ctx(ctx).Debug("reduceInternelRetrieveResults",
+	log.Ctx(ctx).Debug("mergeInternelRetrieveResults",
 		zap.Int64("limit", limit),
 		zap.Int("len(retrieveResults)", len(retrieveResults)),
 	)
@@ -313,7 +313,7 @@ func mergeInternalRetrieveResult(ctx context.Context, retrieveResults []*interna
 }
 
 func mergeSegcoreRetrieveResults(ctx context.Context, retrieveResults []*segcorepb.RetrieveResults, limit int64) (*segcorepb.RetrieveResults, error) {
-	log.Ctx(ctx).Debug("reduceSegcoreRetrieveResults",
+	log.Ctx(ctx).Debug("mergeSegcoreRetrieveResults",
 		zap.Int64("limit", limit),
 		zap.Int("len(retrieveResults)", len(retrieveResults)),
 	)