[FLINK-15584] Give nested data type of ROWs in ValidationException

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.9.1, 1.10.0, 1.11.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: Table SQL / Legacy Planner
• Labels: pull-request-available
• Assignee: Ayush Saxena
• Reporter: Benoît Paris
• Created: 14/Jan/20 11:49
• Updated: 05/Mar/20 06:28
• Resolved: 05/Mar/20 01:30

Description

In 

INSERT INTO baz_sink
SELECT
  a,
  ROW(b, c)
FROM foo_source

Schema mismatch mistakes will not get proper detail level, yielding the following:

Caused by: org.apache.flink.table.api.ValidationException: Field types of query result and registered TableSink [baz_sink] do not match.
Query result schema: [a: Integer, EXPR$2: Row]
TableSink schema: [a: Integer, payload: Row]

Leaving the user with an opaque 'Row' type to debug.

 

Issue Links

• is related to: FLINK-15546 Obscure error message from ScalarOperatorGens::generateCast
• links to: GitHub Pull Request #10978