Flink代码里Json反序列化里有2个参数应该对你有帮助，你到官网上查询下怎么使用
上述2个配置项的参数名字分别是： format.fail-on-missing-field format.ignore-parse-errors 在 2020-12-20 10:48:04，"陈帅" <[email protected]> 写道： >业务上游数据源发出来的数据有可能会有脏数据导致数据无法解析成源表的结构，如kafka json topic映射成源表。 >请问这种情况下flink sql要如何处理? 期望的是将脏数据发到一个专门的topic，是不是要自己写个connector? 标准kafka >connector支持这种需求么？
