fix: Fix consume blocked due to too many consumers

[bigsheeper]

This PR limits the maximum number of consumers per pchannel to 10 for each QueryNode and DataNode.

issue: #37630

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by: bigsheeper
To complete the pull request process, please assign xiaofan-luan after the PR has been reviewed.
You can assign the PR to them by writing /assign @xiaofan-luan in a comment when ready.

The full list of commands accepted by this bot can be found here.

Needs approval from an approver in each of these files:

• OWNERS

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[codecov]

Codecov Report

Attention: Patch coverage is 90.47619% with 8 lines in your changes missing coverage. Please review.

Project coverage is 82.93%. Comparing base (95c1ccc) to head (fa64b46).
Report is 2 commits behind head on master.

Files with missing lines	Patch %	Lines
...hcommon/pipeline/flow_graph_dmstream_input_node.go	85.71%	4 Missing and 1 partial ⚠️
pkg/mq/msgdispatcher/client.go	62.50%	2 Missing and 1 partial ⚠️

Additional details and impacted files

@@             Coverage Diff             @@
##           master   #38455       +/-   ##
===========================================
+ Coverage   69.45%   82.93%   +13.48%     
===========================================
  Files         294     1091      +797     
  Lines       26430   169670   +143240     
===========================================
+ Hits        18357   140717   +122360     
- Misses       8073    23358    +15285     
- Partials        0     5595     +5595     

Components	Coverage Δ
Client	79.12% <ø> (∅)
Core	∅ <ø> (∅)
Go	83.08% <90.47%> (∅)

Files with missing lines	Coverage Δ
internal/datacoord/channel_manager.go	87.61% <100.00%> (ø)
internal/util/pipeline/stream_pipeline.go	93.57% <100.00%> (ø)
pkg/util/paramtable/component_param.go	98.38% <ø> (ø)
pkg/util/paramtable/service_param.go	99.16% <100.00%> (ø)
pkg/mq/msgdispatcher/client.go	95.58% <62.50%> (ø)
...hcommon/pipeline/flow_graph_dmstream_input_node.go	89.04% <85.71%> (ø)

... and 1379 files with indirect coverage changes

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[mergify]

@bigsheeper cpp-unit-test check failed, comment rerun cpp-unit-test can trigger the job again.

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[mergify]

@bigsheeper E2e jenkins job failed, comment /run-cpu-e2e can trigger the job again.

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[bigsheeper]

rerun go-sdk

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[bigsheeper]

rerun go-sdk

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.

[bigsheeper]

rerun go-sdk

[mergify]

@bigsheeper go-sdk check failed, comment rerun go-sdk can trigger the job again.