You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2023/01/19 14:54:50 UTC
[flink] branch master updated (7b69e93b301 -> 6f88d7a9737)

This is an automated email from the ASF dual-hosted git repository.

lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 7b69e93b301 [FLINK-29000][python] Support python UDF in the SQL Gateway (#21725)
     add 714de2ffbc9 [FLINK-30672][sql-parser] Support "EXPLAIN PLAN_ADVICE" syntax
     add 8cb5dffc2e2 [FLINK-30672][table-planner] Introduce PlanAnalyzer and PlanAdvice
     add b2b68944c82 [FLINK-30672][table-planner] Introduce GroupAggregationAnalyzer and support "EXPLAIN PLAN_ADVICE" statement
     add 6f88d7a9737 [FLINK-30672][table-planner] Introduce NonDeterministicUpdateAnalyzer

No new revisions were added by this update.

Summary of changes:
 .../src/test/resources/sql/table.q                 |  35 +-
 .../src/main/codegen/data/Parser.tdd               |   2 +
 .../src/main/codegen/includes/parserImpls.ftl      |   2 +
 .../flink/sql/parser/dql/SqlRichExplain.java       |   5 +-
 .../flink/sql/parser/FlinkSqlParserImplTest.java   |  12 +-
 .../org/apache/flink/table/api/ExplainDetail.java  |   7 +-
 .../planner/analyze/FlinkStreamPlanAnalyzers.java} |  31 +-
 .../planner/analyze/GroupAggregationAnalyzer.java  | 138 ++++++
 .../analyze/NonDeterministicUpdateAnalyzer.java    | 125 +++++
 .../flink/table/planner/analyze/PlanAdvice.java    |  87 ++++
 .../flink/table/planner/analyze/PlanAnalyzer.java} |  48 +-
 .../table/planner/delegation/BatchPlanner.scala    |   4 +
 .../table/planner/delegation/StreamPlanner.scala   |  27 +-
 .../stream/TwoStageOptimizedAggregateRule.scala    |  15 +-
 .../table/planner/plan/utils/FlinkRelOptUtil.scala |  52 ++
 .../planner/plan/utils/RelTreeWriterImpl.scala     |  84 +++-
 .../analyze/GroupAggregationAnalyzerTest.java      | 212 +++++++++
 .../NonDeterministicUpdateAnalyzerTest.java        | 309 ++++++++++++
 .../operations/SqlToOperationConverterTest.java    |   8 +-
 ...tFromToDataStreamAndSqlUpdateWithPlanAdvice.out |  16 +
 .../testSqlUpdateAndToDataStreamWithPlanAdvice.out |  14 +
 .../explain/testStatementSetWithPlanAdvice.out     |  24 +
 .../analyze/GroupAggregationAnalyzerTest.xml       | 521 +++++++++++++++++++++
 .../analyze/NonDeterministicUpdateAnalyzerTest.xml | 189 ++++++++
 .../flink/table/api/TableEnvironmentITCase.scala   |  25 +
 .../flink/table/planner/utils/TableTestBase.scala  |  37 +-
 26 files changed, 1956 insertions(+), 73 deletions(-)
 copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/api/ExplainDetail.java => flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/FlinkStreamPlanAnalyzers.java} (55%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/GroupAggregationAnalyzer.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzer.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/PlanAdvice.java
 copy flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/api/ExplainDetail.java => flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/PlanAnalyzer.java} (51%)
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/GroupAggregationAnalyzerTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/resources/explain/testFromToDataStreamAndSqlUpdateWithPlanAdvice.out
 create mode 100644 flink-table/flink-table-planner/src/test/resources/explain/testSqlUpdateAndToDataStreamWithPlanAdvice.out
 create mode 100644 flink-table/flink-table-planner/src/test/resources/explain/testStatementSetWithPlanAdvice.out
 create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/analyze/GroupAggregationAnalyzerTest.xml
 create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.xml