[jira] [Created] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[Jira]

陈磊 created FLINK-25483:
--------------------------

             Summary: When FlinkSQL writes ES, it will not write and update the 
null value field
                 Key: FLINK-25483
                 URL: https://issues.apache.org/jira/browse/FLINK-25483
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Ecosystem
            Reporter: 陈磊


Using Flink SQL to consume Kafka to write ES, sometimes some fields do not 
exist, and those that do not exist do not want to write ES, how to deal with 
this situation?


For example: the source data has 3 fields, a, b, c
insert into table2
select
a,b,c
from table1
When b=null, only hope to write a and c
When c=null, only hope to write a and b

 

https://mail.qq.com/cgi-bin/frame_html?sid=-ALq0GBmdC3gQRt6&r=0ae7045173744c942614e687d1b972ea



--
This message was sent by Atlassian Jira
(v8.20.1#820001)