diff --git a/internal/querycoordv2/services.go b/internal/querycoordv2/services.go index 9592dc605a..bf67f7721e 100644 --- a/internal/querycoordv2/services.go +++ b/internal/querycoordv2/services.go @@ -930,7 +930,7 @@ func (s *Server) GetShardLeaders(ctx context.Context, req *querypb.GetShardLeade var channelErr error if len(leaders) == 0 { - channelErr = merr.WrapErrChannelLack("channel not subscribed") + channelErr = merr.WrapErrChannelLack(channel.GetChannelName(), "channel not subscribed") } for _, leader := range leaders {