[FLINK-6059] Reject DataSet<Row> and DataStream<Row> without RowTypeInformation

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0, 1.3.0
• Fix Version/s: 1.2.2, 1.3.0
• Component/s: Table SQL / API
• Assignee: Fabian Hueske
• Reporter: Fabian Hueske
• Created: 15/Mar/17 10:15
• Updated: 28/Apr/17 23:42
• Resolved: 28/Apr/17 23:42

Description

It is not possible to automatically extract proper type information for Row because it is not typed with generics and holds values in an Object[].
Consequently is handled as GenericType<Row> unless a RowTypeInfo is explicitly specified.

This can lead to unexpected behavior when converting a DataSet<Row> or DataStream<Row> into a Table. If the data set or data stream has a GenericType<Row>, the rows are treated as atomic type and converted into a single field.

I think we should reject input types of GenericType<Row> when converting data sets and data streams and request a proper RowTypeInfo.

Issue Links

• links to: GitHub Pull Request #3546