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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0, 1.11.0
• Fix Version/s: 1.11.2, 1.12.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available

Environment

mac os 10.15.3

• Assignee: luoziyu
• Reporter: luoziyu
• Created: 17/Jul/20 14:52
• Updated: 24/Jul/20 08:22
• Resolved: 24/Jul/20 08:01

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? 

 

 

 

Issue Links

• links to: GitHub Pull Request #12955