diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go index 8b5f761dce..1f62f9b753 100644 --- a/internal/datacoord/services.go +++ b/internal/datacoord/services.go @@ -933,7 +933,7 @@ func (s *Server) GetFlushState(ctx context.Context, req *milvuspb.GetFlushStateR resp := &milvuspb.GetFlushStateResponse{Status: &commonpb.Status{ErrorCode: commonpb.ErrorCode_UnexpectedError}} if s.isClosed() { log.Warn("failed to get flush state because of closed server", - zap.Int64s("segment ids", req.GetSegmentIDs()), zap.Int("len", len(req.GetSegmentIDs()))) + zap.Int64s("segmentIDs", req.GetSegmentIDs()), zap.Int("len", len(req.GetSegmentIDs()))) resp.Status.Reason = msgDataCoordIsUnhealthy(Params.NodeID) return resp, nil }