diff --git a/internal/querynode/segment.go b/internal/querynode/segment.go index 1304793005..666e224da0 100644 --- a/internal/querynode/segment.go +++ b/internal/querynode/segment.go @@ -294,7 +294,7 @@ func (s *Segment) search(searchReq *searchRequest) (*SearchResult, error) { } var searchResult SearchResult - log.Debug("do search on segment", zap.Int64("segmentID", s.segmentID), zap.Int32("segmentType", int32(s.segmentType))) + log.Debug("do search on segment", zap.Int64("segmentID", s.segmentID), zap.String("segmentType", s.segmentType.String())) tr := timerecord.NewTimeRecorder("cgoSearch") status := C.Search(s.segmentPtr, searchReq.plan.cSearchPlan, searchReq.cPlaceholderGroup, C.uint64_t(searchReq.timestamp), &searchResult.cSearchResult, C.int64_t(s.segmentID)) @@ -329,7 +329,7 @@ func (s *Segment) retrieve(plan *RetrievePlan) (*segcorepb.RetrieveResults, erro status := C.Retrieve(s.segmentPtr, plan.cRetrievePlan, ts, &retrieveResult.cRetrieveResult) metrics.QueryNodeSQSegmentLatencyInCore.WithLabelValues(fmt.Sprint(Params.QueryNodeCfg.GetNodeID()), metrics.QueryLabel).Observe(float64(tr.ElapseSpan().Milliseconds())) - log.Debug("do retrieve on segment", zap.Int64("segmentID", s.segmentID), zap.Int32("segmentType", int32(s.segmentType))) + log.Debug("do retrieve on segment", zap.Int64("segmentID", s.segmentID), zap.String("segmentType", s.segmentType.String())) if err := HandleCStatus(&status, "Retrieve failed"); err != nil { return nil, err }