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