[FLINK-17252] supports SELECT statement in TableEnvironment#executeSql and Table#execute api

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 20/Apr/20 02:17
• Updated: 12/May/20 01:40
• Resolved: 12/May/20 01:40

Description

FLINK-16366 has introduced executeSql method in TableEnvironment, but INSERT statement is not supported because FLINK-17126 is not finished and the design of FLINK-14807 is discussing (the whole design of Table#collect and Table#execute are similar, although Table does not introduce collect method based on the conclusion of FLIP-84). This issue aims to support SELECT statement in TableEnvironment#executeSql and Table#execute api.

Issue Links

• is related to: FLINK-14807 Add TableResult#collect api for fetching data to client
• links to: GitHub Pull Request #12049