You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2020/03/17 08:50:06 UTC

[flink] branch master updated (428c778 -> fac0cf1)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 428c778  [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information
     add fac0cf1  [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

No new revisions were added by this update.

Summary of changes:
 .../harness/GroupAggregateHarnessTest.scala        | 137 +++++++++++++++++++++
 .../operators/aggregate/GroupAggFunction.java      |   7 ++
 .../table/runtime/util/BaseRowHarnessAssertor.java |  12 +-
 .../table/runtime/util/StreamRecordUtils.java      |   9 ++
 4 files changed, 164 insertions(+), 1 deletion(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/harness/GroupAggregateHarnessTest.scala