[jira] [Closed] (FLINK-18632) RowData's row kind do not assigned from input row data when sink code generate and physical type info is pojo type

["Jark Wu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-18632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu closed FLINK-18632.
---------------------------
    Fix Version/s: 1.11.2
                   1.12.0
       Resolution: Fixed

- master: fc3623550f7729795847a37803292c6d3ee4d324
- release-1.11: f8b98cbc4e10e69ff0ea08388224f4994de474d7

> RowData's row kind do not assigned from input row data when sink code generate and physical type info is pojo type
> ------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-18632
>                 URL: https://issues.apache.org/jira/browse/FLINK-18632
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 1.10.0, 1.11.0
>         Environment: mac os 10.15.3
>            Reporter: luoziyu
>            Assignee: luoziyu
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.12.0, 1.11.2
>
>         Attachments: bug.jpg, test_code.png
>
>
> 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? 
>  
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)