pulsar
pulsar copied to clipboard
[improve][broker] Add close function worker
Signed-off-by: Zixuan Liu [email protected]
Motivation
Miss close the function worker when the PulsarService close method is called, which introduces an issue in the test if we don't close the function worker:
We have a broker with function worker, when calling the PulsarService close method, the Pulsar needs to close some services and unload ns, it will break the function worker running, and when the function worker cannot work fine, it will call the PulsarService shutdownNow method, which will close the metadata store, and will affect the running close operation.
Modifications
- Add close function worker to
org.apache.pulsar.broker.PulsarService#closeAsync
Documentation
Check the box below or label this PR directly.
Need to update docs?
-
[ ]
doc-required
(Your PR needs to update docs and you will update later) -
[x]
doc-not-needed
(Please explain why) -
[ ]
doc
(Your PR contains doc changes) -
[ ]
doc-complete
(Docs have been already added)
@nodece Please provide a correct documentation label for your PR. Instructions see Pulsar Documentation Label Guide.