[FLINK-19038] It doesn't support to call Table.limit() continuously

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.12.0
• Fix Version/s: 1.20.0
• Component/s: Table SQL / API
• Labels: auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Dian Fu
• Created: 24/Aug/20 12:13
• Updated: 11/Mar/24 12:44

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.

Issue Links

• links to: GitHub Pull Request #13298