This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f5bce73 [FLINK-21411][rocksdb] Update FRocksDB to bump bzip2
dependency version
add c8ad0ec [FLINK-23434][table-planner-blink] Fix the inconsistent type
in IncrementalAggregateRule when the query has one distinct agg function and
count star agg function
No new revisions were added by this update.
Summary of changes:
.../stream/StreamExecGlobalGroupAggregate.java | 17 +
.../StreamPhysicalGlobalGroupAggregate.scala | 19 +-
.../physical/stream/IncrementalAggregateRule.scala | 21 +-
.../table/planner/plan/utils/AggregateUtil.scala | 33 +
.../stream/IncrementalAggregateJsonPlanTest.java | 21 +
...AggregateWithSumCountDistinctAndRetraction.out} | 662 ++++++++++++---------
.../plan/stream/sql/agg/DistinctAggregateTest.xml | 179 +++++-
.../stream/sql/agg/IncrementalAggregateTest.xml | 41 +-
.../stream/sql/agg/DistinctAggregateTest.scala | 16 +
.../runtime/stream/sql/SplitAggregateITCase.scala | 52 ++
10 files changed, 744 insertions(+), 317 deletions(-)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupAggregateJsonPlanTest_jsonplan/testDistinctAggCalls[isMiniBatchEnabled=true].out
=>
IncrementalAggregateJsonPlanTest_jsonplan/testIncrementalAggregateWithSumCountDistinctAndRetraction.out}
(56%)
