Hi!
You can open a JIRA ticket for this feature. However from my perspective
this feature should only be added to some specific connectors (mostly
message queues) and formats. You might want to attach a list of proposed
connectors and formats in that ticket.
Chong Yun Long 于2021年8月25日周三 下午5:46写道
Hi,
Thanks for the quick response.
The use case is not specific to JDBC (JDBC is just an example) but more for
custom error handling in all connectors.
How would we go about proposing such a new feature to be added to Flink?
On 2021/08/25 09:02:31, Caizhi Weng wrote:
> Hi!>
>
> As far as I
Hi!
As far as I know JDBC does not have this error handling mechanism. Also
there are very few connectors / formats which support skipping
erroneous records (for example the csv format).
Which type of exception are you faced with? As JDBC connectors, unlike
message queue connectors, rarely (if ev
Hi,
Is there any mechanism for handling of errors produced by Flink SQL?
It can be useful for various use cases:
1. Logging exceptions and the erroneous row to a kafka topic
2. Ignoring transient exceptions instead of throwing and failing the entire
job
If there are no such mechanisms may I propo
