This repository has been archived by the owner on Dec 14, 2022. It is now read-only.
[BUG] sink close blocking #498
Labels
Comments
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
Describe the bug
If sink sends a message exception(e.g. send queue full), flink will close sink, but
FlinkPulsarSinkBase.close()will check whether all messages are sent successfully, otherwise it will be blocked bypendingRecordsLock.wait()To Reproduce
Expected behavior
Normal shutdown
Screenshots
Additional context
The text was updated successfully, but these errors were encountered: