This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3a49da6 [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics add bf3587d [FLINK-13656][sql-parser] Bump sql parser Calcite dependency to 1.21.0 add 4f0d804 [FLINK-13656][table-planner][table-planner-blink] Bump flink and blink planner pom and notice file Calcite version to 1.21.0 add d11d0cb [FLINK-13656][table-planner][table-planner-blink] Update implementation about match_recognize because of match partition keys structure change add 8705ecd [FLINK-13656][table-planner] Update converter rule description add b5a2d1d [FLINK-13656][table-planner][table-planner-blink] Update plan change for agg call distinct remove add 1805511 [FLINK-13656][table-planner][table-planner-blink] Update file for Calcite API change add 64a5e83 [FLINK-13656][table-planner-blink] Update plan change because of collapsed IS NOT DISTINCT FROM add 3267f50 [FLINK-13656][table-planner][table-planner-blink] Update files for non equal join condition push down change after sql-to-rel conversion No new revisions were added by this update. Summary of changes: NOTICE-binary | 8 +- flink-table/flink-sql-parser/pom.xml | 5 +- .../src/main/codegen/data/Parser.tdd | 42 +- .../src/main/codegen/includes/parserImpls.ftl | 325 +-- .../calcite/sql/ExtendedSqlRowTypeNameSpec.java | 150 + .../org/apache/calcite/sql/SqlMapTypeNameSpec.java | 103 + .../java/org/apache/calcite/sql}/package-info.java | 10 +- .../apache/flink/sql/parser/ExtendedSqlNode.java | 4 +- .../flink/sql/parser/FlinkSqlDataTypeSpec.java | 325 --- .../flink/sql/parser/ddl/SqlCreateTable.java | 12 +- .../apache/flink/sql/parser/ddl/SqlCreateView.java | 4 +- .../flink/sql/parser/ddl/SqlTableColumn.java | 8 +- .../apache/flink/sql/parser/dml/RichSqlInsert.java | 4 +- ...rseException.java => SqlValidateException.java} | 11 +- ...Type.java => ExtendedSqlBasicTypeNameSpec.java} | 42 +- .../type/ExtendedSqlCollectionTypeNameSpec.java | 129 + .../flink/sql/parser/type/ExtendedSqlType.java | 42 - .../apache/flink/sql/parser/type/SqlArrayType.java | 49 - .../apache/flink/sql/parser/type/SqlBytesType.java | 38 - .../apache/flink/sql/parser/type/SqlMapType.java | 59 - .../apache/flink/sql/parser/type/SqlRowType.java | 94 - .../flink/sql/parser/type/SqlStringType.java | 38 - .../apache/flink/sql/parser/type/SqlTimeType.java | 73 - .../flink/sql/parser/type/SqlTimestampType.java | 73 - .../flink/sql/parser/FlinkDDLDataTypeTest.java | 206 +- .../flink/sql/parser/FlinkSqlParserImplTest.java | 32 +- flink-table/flink-table-planner-blink/pom.xml | 8 +- .../java/org/apache/calcite/sql/SqlFunction.java | 322 +++ .../apache/calcite/sql2rel/RelDecorrelator.java | 2856 -------------------- .../operations/SqlToOperationConverter.java | 14 +- ...FlinkAggregateExpandDistinctAggregatesRule.java | 95 +- .../plan/rules/logical/FlinkFilterJoinRule.java | 363 --- .../logical/FlinkJoinPushExpressionsRule.java | 5 +- .../rules/logical/FlinkJoinToMultiJoinRule.java | 594 ---- .../src/main/resources/META-INF/NOTICE | 4 +- .../planner/calcite/FlinkLogicalRelFactories.scala | 6 +- .../table/planner/calcite/FlinkPlannerImpl.scala | 34 +- .../table/planner/calcite/FlinkRelBuilder.scala | 4 +- .../table/planner/calcite/FlinkTypeFactory.scala | 22 +- .../table/planner/calcite/FlinkTypeSystem.scala | 27 +- .../calcite/RelTimeIndicatorConverter.scala | 5 +- .../table/planner/codegen/ExprCodeGenerator.scala | 5 + .../table/planner/codegen/MatchCodeGenerator.scala | 22 +- .../planner/codegen/calls/ScalarOperatorGens.scala | 10 + .../planner/plan/logical/MatchRecognize.scala | 3 +- .../plan/nodes/logical/FlinkLogicalMatch.scala | 34 +- .../nodes/physical/stream/StreamExecMatch.scala | 12 +- .../planner/plan/rules/FlinkBatchRuleSets.scala | 6 +- .../planner/plan/rules/FlinkStreamRuleSets.scala | 6 +- .../physical/stream/StreamExecMatchRule.scala | 31 +- .../table/planner/plan/utils/FlinkRelOptUtil.scala | 170 +- .../planner/plan/batch/sql/DeadlockBreakupTest.xml | 2 +- .../planner/plan/batch/sql/SetOperatorsTest.xml | 2 +- .../batch/sql/agg/AggregateReduceGroupingTest.xml | 14 +- .../plan/batch/sql/agg/DistinctAggregateTest.xml | 2 +- .../plan/batch/sql/join/BroadcastHashJoinTest.xml | 60 +- .../sql/join/BroadcastHashSemiAntiJoinTest.xml | 2 +- .../plan/batch/sql/join/NestedLoopJoinTest.xml | 90 +- .../batch/sql/join/NestedLoopSemiAntiJoinTest.xml | 16 +- .../plan/batch/sql/join/SemiAntiJoinTest.xml | 16 +- .../plan/batch/sql/join/ShuffledHashJoinTest.xml | 90 +- .../sql/join/ShuffledHashSemiAntiJoinTest.xml | 2 +- .../plan/batch/sql/join/SortMergeJoinTest.xml | 92 +- .../batch/sql/join/SortMergeSemiAntiJoinTest.xml | 2 +- .../table/planner/plan/batch/table/JoinTest.xml | 12 +- .../logical/AggregateReduceGroupingRuleTest.xml | 22 +- ...nkAggregateExpandDistinctAggregatesRuleTest.xml | 4 +- .../rules/logical/FlinkAggregateRemoveRuleTest.xml | 2 +- .../plan/rules/logical/FlinkFilterJoinRuleTest.xml | 64 +- .../logical/subquery/SubQueryAntiJoinTest.xml | 40 +- .../logical/subquery/SubQuerySemiJoinTest.xml | 24 +- .../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +- .../planner/plan/stream/sql/join/JoinTest.xml | 24 +- .../plan/stream/sql/join/SemiAntiJoinTest.xml | 18 +- .../planner/plan/stream/table/AggregateTest.xml | 4 +- .../table/planner/plan/stream/table/JoinTest.xml | 8 +- .../planner/expressions/TemporalTypesTest.scala | 2 +- .../FlinkAggregateJoinTransposeRuleTest.scala | 4 +- .../rules/logical/FlinkFilterJoinRuleTest.scala | 8 +- .../logical/FlinkJoinToMultiJoinRuleTest.scala | 6 +- .../JoinDependentConditionDerivationRuleTest.scala | 5 +- .../RewriteMultiJoinConditionRuleTest.scala | 6 +- flink-table/flink-table-planner/pom.xml | 8 +- .../java/org/apache/calcite/sql/SqlFunction.java | 322 +++ .../calcite/sql/validate/SqlValidatorImpl.java | 34 + .../table/sqlexec/SqlToOperationConverter.java | 14 +- .../src/main/resources/META-INF/NOTICE | 4 +- .../flink/table/calcite/FlinkPlannerImpl.scala | 32 +- .../flink/table/calcite/FlinkRelBuilder.scala | 4 +- .../table/calcite/RelTimeIndicatorConverter.scala | 5 +- .../flink/table/codegen/MatchCodeGenerator.scala | 18 +- .../flink/table/plan/logical/MatchRecognize.scala | 4 +- .../table/plan/nodes/CommonMatchRecognize.scala | 16 +- .../plan/nodes/datastream/DataStreamMatch.scala | 9 +- .../plan/nodes/logical/FlinkLogicalMatch.scala | 36 +- .../table/plan/rules/dataSet/DataSetCalcRule.scala | 2 +- .../plan/rules/dataSet/DataSetCorrelateRule.scala | 2 +- .../plan/rules/dataSet/DataSetDistinctRule.scala | 2 +- .../table/plan/rules/dataSet/DataSetJoinRule.scala | 2 +- .../rules/dataSet/DataSetSingleRowJoinRule.scala | 2 +- .../plan/rules/dataSet/DataSetValuesRule.scala | 2 +- .../plan/rules/datastream/DataStreamCalcRule.scala | 2 +- .../rules/datastream/DataStreamCorrelateRule.scala | 2 +- .../plan/rules/datastream/DataStreamJoinRule.scala | 2 +- .../rules/datastream/DataStreamMatchRule.scala | 32 +- .../plan/rules/datastream/DataStreamSortRule.scala | 2 +- .../DataStreamTemporalTableJoinRule.scala | 2 +- .../rules/datastream/DataStreamValuesRule.scala | 2 +- .../datastream/DataStreamWindowJoinRule.scala | 2 +- .../api/batch/sql/DistinctAggregateTest.scala | 19 +- .../flink/table/api/batch/sql/JoinTest.scala | 20 +- .../api/stream/sql/DistinctAggregateTest.scala | 2 +- .../flink/table/api/stream/sql/JoinTest.scala | 12 +- .../table/api/stream/table/AggregateTest.scala | 2 +- .../runtime/harness/TemporalJoinHarnessTest.scala | 5 +- flink-table/pom.xml | 1 + 116 files changed, 2064 insertions(+), 5752 deletions(-) create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/ExtendedSqlRowTypeNameSpec.java create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/SqlMapTypeNameSpec.java copy {flink-tests/src/test/java/org/apache/flink/test/manual => flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql}/package-info.java (73%) delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/FlinkSqlDataTypeSpec.java rename flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/error/{SqlParseException.java => SqlValidateException.java} (79%) rename flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/{SqlMultisetType.java => ExtendedSqlBasicTypeNameSpec.java} (53%) create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/ExtendedSqlCollectionTypeNameSpec.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/ExtendedSqlType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlArrayType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlBytesType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlMapType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlRowType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlStringType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlTimeType.java delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlTimestampType.java create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlFunction.java delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql2rel/RelDecorrelator.java delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRule.java create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlFunction.java