[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111907#comment-17111907 ]
Danny Chen commented on FLINK-17174: ------------------------------------ This is an duplicate issue of FLINK-16160, so i would close it, feel free to re-open it when the bug still exists. > 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 > Components: Table SQL / API, Table SQL / Planner > Affects Versions: 1.10.0 > Reporter: Yiwen Tu > Priority: Critical > Fix For: 1.11.0 > > 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 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)