[FLINK-6780] ExternalTableSource should add time attributes in the row type

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.3.1, 1.4.0
• Component/s: Table SQL / API
• Assignee: Haohui Mai
• Reporter: Haohui Mai
• Created: 31/May/17 00:50
• Updated: 06/Jun/17 10:30
• Resolved: 31/May/17 11:43

Description

We observed that all streaming queries that refer to external tables fail when the Volcano planner converting LogicalTableScan to FlinkLogicalTableSourceScan:

Type mismatch:
rowtype of new rel:
RecordType(<table schema>, TIMESTAMP(3) NOT NULL proctime) NOT NULL
rowtype of set:
RecordType(<table schema>, ...) NOT NULL

Tables that are registered through StreamTableEnvironment#registerTableSource() do not suffer from this problem as StreamTableSourceTable adds the processing time / event time attribute automatically.

Issue Links

• links to: GitHub Pull Request #4023