我们内部是给json format加了一个功能，允许不把null字段进行序列化。主要解决的也是es这个写入的场景。 你们也可以试一下。
RS <tinyshr...@163.com> 于2021年12月29日周三 16:41写道： > Hi， > 使用Flink SQL消费Kafka写ES，有时候有的字段不存在，不存在的不想写入ES，这种情况怎么处理呢？ > > > 比如：源数据有3个字段，a,b,c > insert into table2 > select > a,b,c > from table1 > 当b=null的时候，只希望写入a和c > 当c=null的时候，只希望写入a和b > > -- Best, Benchao Li
