Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20787 Improve the Table API to make it usable
  3. FLINK-19038

It doesn't support to call Table.limit() continuously

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      For example, table.limit(3).limit(2) will failed with "FETCH is already defined."

      org.apache.flink.table.api.ValidationException: FETCH is already defined.
      
      	at org.apache.flink.table.operations.utils.SortOperationFactory.validateAndGetChildSort(SortOperationFactory.java:125)
      	at org.apache.flink.table.operations.utils.SortOperationFactory.createLimitWithFetch(SortOperationFactory.java:105)
      	at org.apache.flink.table.operations.utils.OperationTreeBuilder.limitWithFetch(OperationTreeBuilder.java:418)
      

      However, as we support to call table.limit() without specifying the order, I guess this should be a valid usage and should be allowed.

        Attachments

          Activity

            People

            • Assignee:
              nicholasjiang Nicholas Jiang
              Reporter:
              dian.fu Dian Fu

              Dates

              • Created:
                Updated:

                Issue deployment