You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by RS <ti...@163.com> on 2022/10/05 08:00:28 UTC

Re:如何处理Flink KafkaSource的异常的数据

Hi，


当前的SQL是不支持的，需要的话，可以自己实现一个connector或者UDF，把错误数据输出到其他地方


Thanks




在 2022-09-29 10:02:34，"Summer" <bi...@paat.com> 写道：
>
>你好，我想问一下，如果来源于Kakfka的一条数据出现错误，会导致任务执行失败，日志抛出该条错误数据。
>
>
>为保证任务执行，需要在*** WITH内加'value.json.ignore-parse-errors' = 'true',  'value.json.fail-on-missing-field' = 'false'
>
>
>
>
>那么之后如果出现异常的数据，我应该怎么感知到呢？？
>
>
>
>
>
>
>
>