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

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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.2.0, 1.3.0
    • 1.2.2, 1.3.0
    • Table SQL / API
    • 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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment