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

RowData's row kind do not assigned from input row data when sink code generate and physical type info is pojo type

    XMLWordPrintableJSON

    Details

      Description

      I use tuple type and pojo type to test retract stream, the test data is same and when i use 

      toRetractStream(Table table, Class<T> clazz) api, the retract msg become to insert msg from sink conversion. I found the SinkCodeGenerator object did not give a row kind to afterIndexModify variable, so the delete msg become insert msg when it comes into processElement function generator by SinkCodeGenerator.

      At last i add line of code like the pic in attachment and it works, so is it a bug? 

       

       

       

        Attachments

        1. bug.jpg
          121 kB
          luoziyu
        2. test_code.png
          241 kB
          luoziyu

          Issue Links

            Activity

              People

              • Assignee:
                lzy3261944 luoziyu
                Reporter:
                lzy3261944 luoziyu
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: