[FLINK-15083] Fix connectors only pick physical fields from TableSchema

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Connectors / Common, Table SQL / Planner
• Assignee: Unassigned
• Reporter: Jark Wu
• Created: 05/Dec/19 16:05
• Updated: 17/Dec/19 13:31
• Resolved: 17/Dec/19 13:31

Description

Currently, all the connectors will derive TableSchema from properties. But after introducing computed columns, the TableSchema contains generated columns. However, almost all the connectors use the drived TableSchema as TableSource#getTableSchema and TableSource#getProducedDataType which may produce wrong result.

Issue Links

• is duplicated by: FLINK-15191 Fix can't create table source for Kafka if watermark or computed column is defined