You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yiwen Tu (Jira)" <ji...@apache.org> on 2020/04/16 05:14:00 UTC
[jira] [Updated] (FLINK-17174) Conversion to relational algebra
failed to preserve datatypes when using Table API but succeed when using
SQL query
[ 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)