Yiwen Tu created FLINK-17174:
--------------------------------
Summary: 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
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!
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!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
