Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6059

Reject DataSet<Row> and DataStream<Row> without RowTypeInformation

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.3.0
    • Fix Version/s: 1.3.0, 1.2.2
    • Component/s: Table API & SQL
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                fhueske Fabian Hueske
                Reporter:
                fhueske Fabian Hueske
              • Votes:
                1 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: