You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/12/30 08:24:03 UTC
[flink] branch master updated (2298fae -> ec893d2)

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 2298fae  [hotfix][connectors][docs] Use big M letters for month in date format
     add 071f036  [hotfix][table-planner] Code fixes for Aggregate Functions
     add 9c419fd  [hotfix][table-planner][tests] Fix test for SumWithRetractAgg
     add ec893d2  [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

No new revisions were added by this update.

Summary of changes:
 .../functions/BuiltInFunctionDefinitions.java      |  26 +++-
 .../strategies/AggDecimalPlusTypeStrategy.java     |   9 +-
 .../planner/expressions/ExpressionBuilder.java     |  18 ++-
 .../functions/aggfunctions/AvgAggFunction.java     |  52 +++++--
 .../functions/aggfunctions/CollectAggFunction.java |   2 +-
 .../functions/aggfunctions/Count1AggFunction.java  |   3 +-
 .../functions/aggfunctions/CountAggFunction.java   |   3 +-
 .../aggfunctions/FirstValueAggFunction.java        |   2 +-
 .../FirstValueWithRetractAggFunction.java          |   2 +-
 .../functions/aggfunctions/LagAggFunction.java     |   1 -
 .../aggfunctions/LastValueAggFunction.java         |   2 +-
 .../LastValueWithRetractAggFunction.java           |   2 +-
 .../functions/aggfunctions/LeadLagAggFunction.java |   6 +-
 .../functions/aggfunctions/ListAggFunction.java    |  11 +-
 .../functions/aggfunctions/MaxAggFunction.java     |   9 +-
 .../aggfunctions/MaxWithRetractAggFunction.java    |   2 +-
 .../functions/aggfunctions/MinAggFunction.java     |   9 +-
 .../aggfunctions/MinWithRetractAggFunction.java    |   2 +-
 .../functions/aggfunctions/RankAggFunction.java    |   2 +-
 .../aggfunctions/RankLikeAggFunctionBase.java      |   1 +
 .../aggfunctions/RowNumberAggFunction.java         |   3 +-
 .../aggfunctions/SingleValueAggFunction.java       |  22 ++-
 .../functions/aggfunctions/Sum0AggFunction.java    |  44 +++++-
 .../functions/aggfunctions/SumAggFunction.java     |  21 ++-
 .../aggfunctions/SumWithRetractAggFunction.java    |  74 +++++----
 .../table/planner/codegen/ExprCodeGenerator.scala  |   5 +
 .../runtime/stream/sql/AggregateITCase.scala       | 169 +++++++++++++++++----
 .../runtime/stream/table/AggregateITCase.scala     |  50 ++++++
 28 files changed, 408 insertions(+), 144 deletions(-)