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

Posted to commits@flink.apache.org by hx...@apache.org on 2021/05/18 01:57:29 UTC

[flink] branch master updated (80ef986 -> 06dec01)

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

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


    from 80ef986  [FLINK-22620][orc] Drop BatchTableSource OrcTableSource and related classes
     add 06dec01  [FLINK-22651][python][table-planner-blink] Support StreamExecPythonGroupAggregate json serialization/deserialization

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/tests/test_udaf.py      |  38 +++++
 .../stream/StreamExecPythonGroupAggregate.java     |  53 ++++++-
 .../nodes/exec/stream/JsonSerdeCoverageTest.java   |   1 -
 ....java => PythonGroupAggregateJsonPlanTest.java} |  25 ++-
 .../tesPythonAggCallsWithGroupBy.out}              | 176 ++++++---------------
 5 files changed, 140 insertions(+), 153 deletions(-)
 copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{RankJsonPlanTest.java => PythonGroupAggregateJsonPlanTest.java} (74%)
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupAggregateJsonPlanTest_jsonplan/testSimpleAggCallsWithGroupBy[isMiniBatchEnabled=false].out => PythonGroupAggregateJsonPlanTest_jsonplan/tesPythonAggCallsWithGroupBy.out} (66%)