Hi, guaishushu 贴query或者图床链接吧，flink-sql中的json的解析支持是比较全的[1]，可以把json的 schema 和 异常数据贴下吗？ 用个单元测试应该就可以复现问题
Best, Leonard [1] https://github.com/apache/flink/blob/master/flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDeserializationSchemaTest.java <https://github.com/apache/flink/blob/master/flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDeserializationSchemaTest.java> > 在 2020年5月20日，15:51，guaishushu1...@163.com <mailto:guaishushu1...@163.com> 写道： > > kafka数据写入kafka 数据，flink1.10-sql解析复杂json中字段为string，导致数据丢失。 > > > > > > > > guaishushu1...@163.com <mailto:guaishushu1...@163.com>
