This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from ac32c9f [FLINK-25230][table-planner] Regenerate JSON plans add 6def8d7 [FLINK-25392][table-planner] Support new EXECUTE STATEMENT SET BEGIN ... END; syntax No new revisions were added by this update. Summary of changes: .../src/main/codegen/data/Parser.tdd | 3 + .../src/main/codegen/includes/parserImpls.ftl | 49 ++++++++++ .../SqlRichExplain.java => dml/SqlExecute.java} | 50 +++++----- .../SqlStatementSet.java} | 67 ++++++------- .../flink/sql/parser/FlinkSqlParserImplTest.java | 45 +++++++++ .../table/api/internal/TableEnvironmentImpl.java | 19 +++- .../operations/BeginStatementSetOperation.java | 5 +- .../table/operations/EndStatementSetOperation.java | 5 +- .../flink/table/operations/ExplainOperation.java | 5 +- .../table/operations/StatementSetOperation.java | 31 +++++- .../planner/calcite/FlinkCalciteSqlValidator.java | 14 --- .../operations/SqlToOperationConverter.java | 38 ++++++-- .../table/planner/calcite/FlinkPlannerImpl.scala | 37 ++++--- .../calcite/FlinkCalciteSqlValidatorTest.java | 19 +++- .../operations/SqlToOperationConverterTest.java | 90 +++++++++++++++++ .../explain/testStatementSetExecutionExplain.out | 71 ++++++++++++++ .../flink/table/api/TableEnvironmentITCase.scala | 46 ++++++++- .../flink/table/api/TableEnvironmentTest.scala | 107 ++++++++++++++++----- 18 files changed, 567 insertions(+), 134 deletions(-) copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dql/SqlRichExplain.java => dml/SqlExecute.java} (64%) copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dql/SqlRichExplain.java => dml/SqlStatementSet.java} (54%)