[BUG] sink close blocking
mmaxiaolei opened this issue · 0 comments
mmaxiaolei commented
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 by pendingRecordsLock.wait()
To Reproduce
Expected behavior
Normal shutdown
Screenshots
Additional context