[flink] branch release-1.9 updated (88458eb -> 2fef590)

[ja...@apache.org]

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(-)