[FLINK-25392] Add new STATEMENT SET syntax

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Table SQL / API
• Labels: pull-request-available

Release Note

It is recommended to update statement sets to the new SQL syntax: EXECUTE STATEMENT SET BEGIN ... END;
EXPLAIN STATEMENT SET BEGIN ... END;

• Assignee: Wenlong Lyu
• Reporter: Timo Walther
• Created: 20/Dec/21 12:56
• Updated: 14/Jan/22 08:24
• Resolved: 14/Jan/22 08:24

Description

Support:

EXECUTE STATEMENT SET
BEGIN
  INSERT INTO pageview_pv_sink
  SELECT page_id, count(1) FROM clicks GROUP BY page_id;

  INSERT INTO pageview_uv_sink
  SELECT page_id, count(distinct user_id) FROM clicks GROUP BY page_id;
END;

EXPLAIN STATEMENT SET
BEGIN
  INSERT INTO pageview_pv_sink
  SELECT page_id, count(1) FROM clicks GROUP BY page_id;

  INSERT INTO pageview_uv_sink
  SELECT page_id, count(distinct user_id) FROM clicks GROUP BY page_id;
END;

This time we should add this to the SQL parser. We need to figure out a solution for the interactive SQL Client.

Issue Links

• is related to: FLINK-25600 Support new statement set syntax in sql client and update docs
• links to: GitHub Pull Request #18215