Hi,
感谢回复,我也测试过这类方法,
我给json format加了个参数,在序列化的时候,row里面去除null,但是这个要修改代码,单独更新flink-json的jar包了,后期维护可能会有问题
这种很适合写ES和写文件,不会有冗余的字段
如果社区能新增这个功能或者合并进去就方便了
在 2022-01-06 21:18:37,"Benchao Li" 写道:
>我们内部是给json format加了一个功能,允许不把null字段进行序列化。主要解决的也是es这个写入的场景。
>你们也可以试一下。
>
>RS 于2021年12月29日周三 16:41写道:
>
>> Hi,
>>
有10~20个字段,这样一个个写,手都敲断了,还有其他的方式吗?或者如何开发代码适配到SQL?
在 2021-12-30 11:36:21,"Xuyang" 写道:
>可以使用case when试一下
>在 2021-12-29 16:40:39,"RS" 写道:
>>Hi,
>>使用Flink SQL消费Kafka写ES,有时候有的字段不存在,不存在的不想写入ES,这种情况怎么处理呢?
>>
>>
>>比如:源数据有3个字段,a,b,c
>>insert into table2
>>select
>>a,b,c
>>from table1
>>当b=null的时候,只希望写入