This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git.
from 88458eb [FLINK-13600][table] Rework TableEnvironment.connect() class hierarchy add c27ea21 [FLINK-13523][table-planner-blink] Refactor DIVIDE function to keep it compatible with old planner add dc2f8a2 [FLINK-13523][table-planner-blink] Remove non-standard bitwise scalar function and DIV(), DIV_INT() function from blink planner add 2fef590 [FLINK-13523][table-planner-blink] Refactor AVG aggregate function to keep it compatible with old planner No new revisions were added by this update. Summary of changes: .../functions/aggfunctions/AvgAggFunction.java | 83 +++++++++++++- .../aggfunctions/DeclarativeAggregateFunction.java | 3 + .../functions/sql/FlinkSqlOperatorTable.java | 74 +----------- .../table/planner/calcite/FlinkTypeSystem.scala | 2 +- .../codegen/agg/DeclarativeAggCodeGen.scala | 2 +- .../codegen/agg/batch/AggCodeGenHelper.scala | 1 - .../codegen/agg/batch/HashAggCodeGenHelper.scala | 1 - .../planner/codegen/calls/FunctionGenerator.scala | 109 ------------------ .../planner/expressions/ReturnTypeInference.scala | 5 +- .../plan/rules/logical/SplitAggregateRule.scala | 23 +++- .../planner/plan/utils/AggFunctionFactory.scala | 15 ++- .../table/planner/codegen/agg/TestLongAvgFunc.java | 6 +- .../planner/plan/batch/sql/RemoveCollationTest.xml | 4 +- .../planner/plan/batch/sql/RemoveShuffleTest.xml | 12 +- .../planner/plan/batch/sql/SubplanReuseTest.xml | 10 +- .../batch/sql/agg/AggregateReduceGroupingTest.xml | 12 +- .../plan/batch/sql/agg/HashAggregateTest.xml | 12 +- .../plan/batch/sql/agg/OverAggregateTest.xml | 20 ++-- .../plan/batch/sql/agg/SortAggregateTest.xml | 12 +- .../plan/batch/sql/agg/WindowAggregateTest.xml | 18 +-- .../logical/AggregateReduceGroupingRuleTest.xml | 12 +- .../plan/rules/logical/SplitAggregateRuleTest.xml | 4 +- .../rules/logical/WindowGroupReorderRuleTest.xml | 24 ++-- .../logical/subquery/SubQuerySemiJoinTest.xml | 16 ++- .../planner/plan/stream/sql/agg/AggregateTest.xml | 4 +- .../plan/stream/sql/agg/DistinctAggregateTest.xml | 12 +- .../stream/sql/agg/IncrementalAggregateTest.xml | 4 +- .../plan/stream/sql/agg/OverAggregateTest.xml | 4 +- .../plan/stream/sql/agg/WindowAggregateTest.xml | 6 +- .../planner/plan/stream/table/GroupWindowTest.xml | 4 +- .../table/planner/codegen/agg/AggTestBase.scala | 9 +- .../codegen/agg/AggsHandlerCodeGeneratorTest.scala | 13 +-- .../codegen/agg/batch/AggWithoutKeysTest.scala | 9 +- .../codegen/agg/batch/BatchAggTestBase.scala | 8 +- .../agg/batch/HashAggCodeGeneratorTest.scala | 13 +-- .../agg/batch/SortAggCodeGeneratorTest.scala | 8 +- .../planner/expressions/ScalarFunctionsTest.scala | 65 +---------- .../planner/expressions/SqlExpressionTest.scala | 28 +---- .../metadata/AggCallSelectivityEstimatorTest.scala | 2 - .../FlinkRelMdFilteredColumnIntervalTest.scala | 5 +- .../planner/runtime/batch/sql/DecimalITCase.scala | 19 ---- .../planner/runtime/batch/sql/MiscITCase.scala | 2 +- .../runtime/batch/sql/OverWindowITCase.scala | 120 ++++++++++---------- .../batch/sql/agg/AggregateITCaseBase.scala | 26 ++--- .../sql/agg/AggregateReduceGroupingITCase.scala | 32 +++--- .../runtime/batch/sql/agg/GroupingSetsITCase.scala | 120 ++++++++++---------- .../batch/sql/agg/WindowAggregateITCase.scala | 44 ++++---- .../runtime/batch/table/AggregationITCase.scala | 18 +-- .../runtime/stream/sql/AggregateITCase.scala | 12 +- .../runtime/stream/sql/MatchRecognizeITCase.scala | 2 +- .../runtime/stream/sql/OverWindowITCase.scala | 124 ++++++++++----------- .../planner/runtime/stream/sql/RankITCase.scala | 8 +- .../runtime/stream/sql/SplitAggregateITCase.scala | 4 +- .../runtime/stream/table/AggregateITCase.scala | 6 +- .../runtime/stream/table/GroupWindowITCase.scala | 10 +- .../stream/table/MiniBatchGroupWindowITCase.scala | 8 +- .../runtime/stream/table/OverWindowITCase.scala | 32 +++--- .../flink/table/planner/utils/AvgAggFunction.scala | 24 ++-- 58 files changed, 541 insertions(+), 744 deletions(-)