Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25483

When FlinkSQL writes ES, it will not write and update the null value field

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Closed
    • Minor
    • Resolution: Won't Fix
    • None
    • None
    • Table SQL / Ecosystem
    • None

    Description

      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

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            empcl 陈磊
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: