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

回复