[FLINK-16160] Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

• Type: Sub-task
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.10.2, 1.11.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Zhenghua Gao
• Reporter: Zhenghua Gao
• Created: 19/Feb/20 08:52
• Updated: 16/Oct/20 10:50
• Resolved: 19/May/20 06:17

Description

In ConnectTableDescriptor#createTemporaryTable, the proctime/rowtime properties are ignored so the generated catalog table is not correct. We should fix this to let TableEnvironment#connect() support watermark.

Issue Links

• duplicates: FLINK-17174 Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query
• duplicates: FLINK-17179 Set row time attribute not working in connector descriptor
• duplicates: FLINK-17317 Schema.rowtime() method not working correctly, throws 'Window aggregate can only be defined over a time attribute column' exception
• duplicates: FLINK-17600 Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation
• links to: Flink 1.10 createTemporaryTable() loses proctime information
• links to: GitHub Pull Request #11837
• links to: GitHub Pull Request #12218