Immediately throw Exception in mailbox executor rather than wait until next record in flink sink writer.

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

In currently flink sink, checkAsyncException is trigger by newly coming record or checkpoint. It's better to throw Exception in mailbox executor  rather than wait until next record in flink sink writer.

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!