Fix pulsar reader not close

[godchen0212]

Fix pulsar reader not close
Issue #13214

Signed-off-by: godchen0212 [email protected]

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[bigsheeper]

/lgtm

[mergify]

@godchen0212 ut workflow job failed, comment rerun ut can trigger the job again.

[bigsheeper]

/lgtm

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 ut workflow job failed, comment rerun ut can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 ut workflow job failed, comment rerun ut can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[wxyucs]

/approve

[sre-ci-robot]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: godchen0212, scsven

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

The pull request process is described here

Needs approval from an approver in each of these files:

• internal/msgstream/OWNERS [scsven]
• internal/querynode/OWNERS [scsven]
• internal/util/OWNERS [scsven]

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

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[mergify]

@godchen0212 E2e jenkins job failed, comment /run-checks can trigger the job again.

[codecov]

Codecov Report

Merging #14543 (facd464) into master (cd43b12) will increase coverage by 0.02%.
The diff coverage is 82.75%.

@@            Coverage Diff             @@
##           master   #14543      +/-   ##
==========================================
+ Coverage   80.11%   80.13%   +0.02%     
==========================================
  Files         442      442              
  Lines       60912    60931      +19     
==========================================
+ Hits        48798    48828      +30     
+ Misses       9762     9751      -11     
  Partials     2352     2352              

Impacted Files	Coverage Δ
internal/querynode/task.go	79.21% <0.00%> (ø)
...nternal/util/rocksmq/client/rocksmq/client_impl.go	75.63% <ø> (-2.71%)	⬇️
internal/querynode/segment_loader.go	63.40% <40.00%> (-0.44%)	⬇️
...ternal/util/rocksmq/server/rocksmq/rocksmq_impl.go	81.70% <91.66%> (-0.65%)	⬇️
internal/msgstream/mq_msgstream.go	75.54% <100.00%> (-0.24%)	⬇️
internal/util/mqclient/rmq_client.go	63.49% <100.00%> (-0.58%)	⬇️
internal/util/mqclient/rmq_consumer.go	89.18% <100.00%> (+0.61%)	⬆️
internal/util/mqclient/rmq_producer.go	100.00% <100.00%> (ø)
... and 13 more

[fishpenguin]

/lgtm