[FLINK-17174] Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Duplicate
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: Table SQL / API, Table SQL / Planner
• Assignee: Unassigned
• Reporter: Yiwen Tu
• Created: 16/Apr/20 05:12
• Updated: 20/May/20 08:18
• Resolved: 20/May/20 08:18

Description

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:

 The Error is :

But when I use SqlQuery, it works:

Issue Links

• is duplicated by: FLINK-16160 Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path