可以使用case when试一下
在 2021-12-29 16:40:39,"RS" <tinyshr...@163.com> 写道:
>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
>

回复