[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yiwen Tu updated FLINK-17174: ----------------------------- Description: I read data from kafka source name and the source table has the fields of 'ts' which has the row time attributes, after that I add an column whose type is int and default value is 0. After that, the kafka source will be join with a table. And the code is below: !image-2020-04-16-13-08-33-752.png|width=2329,height=253! The Error is : !image-2020-04-16-13-08-59-149.png! But when I use SqlQuery, it works: !image-2020-04-16-13-12-32-212.png|width=1230,height=47! was: I read data from kafka source name and the source table has the fields of 'ts' which has the row time attributes, after that I add an column whose type is int and default value is 0. After that, the kafka source will be join with a table. And the code is below: !image-2020-04-16-13-08-33-752.png! The Error is : !image-2020-04-16-13-08-59-149.png! But when I use SqlQuery, it works: !image-2020-04-16-13-12-32-212.png! > Conversion to relational algebra failed to preserve datatypes when using > Table API but succeed when using SQL query > ------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-17174 > URL: https://issues.apache.org/jira/browse/FLINK-17174 > Project: Flink > Issue Type: Bug > Reporter: Yiwen Tu > Priority: Major > Attachments: image-2020-04-16-12-54-19-574.png, > image-2020-04-16-13-08-33-752.png, image-2020-04-16-13-08-59-149.png, > image-2020-04-16-13-12-32-212.png > > > I read data from kafka source name and the source table has the fields of > 'ts' which has the row time attributes, after that I add an column whose > type is int and default value is 0. After that, the kafka source will be join > with a table. And the code is below: > !image-2020-04-16-13-08-33-752.png|width=2329,height=253! > The Error is : > !image-2020-04-16-13-08-59-149.png! > But when I use SqlQuery, it works: > !image-2020-04-16-13-12-32-212.png|width=1230,height=47! -- This message was sent by Atlassian Jira (v8.3.4#803005)