HI > 在 2020年9月9日，16:37，marble.zh...@coinflex.com.invalid > <marble.zh...@coinflex.com.INVALID> 写道： > > 如果某个message出现exception时
table的connector, 你用的format是什么？一般这种某条message解析异常引起的失败都是可以跳过，比如配置下json.ignore-parse-errors(json) 或 csv.ignore-parse-errors（csv）。 [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/json.html#json-ignore-parse-errors <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/json.html#json-ignore-parse-errors> [2] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/csv.html#csv-ignore-parse-errors <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/formats/csv.html#csv-ignore-parse-errors>
