[flink] branch master updated (fdcadc4 -> f026dd6)

[go...@apache.org]

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

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


    from fdcadc4  [FLINK-21791][table-planner-blink] Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization
     add f026dd6  [FLINK-21860][table-planner-blink] Support StreamExecExpand json serialization/deserialization

No new revisions were added by this update.

Summary of changes:
 .../plan/nodes/exec/batch/BatchExecExpand.java     |   4 +-
 .../plan/nodes/exec/common/CommonExecExpand.java   |  25 +-
 .../plan/nodes/exec/stream/StreamExecExpand.java   |  24 +-
 ...itJsonPlanTest.java => ExpandJsonPlanTest.java} |  33 +-
 .../nodes/exec/stream/JsonSerdeCoverageTest.java   |   1 -
 .../jsonplan/ChangelogSourceJsonPlanITCase.java    |   6 +-
 .../stream/jsonplan/ExpandJsonPlanITCase.java      |  70 +++
 .../jsonplan/GroupAggregateJsonPlanITCase.java     |   8 +-
 .../stream/jsonplan/TableSourceJsonPlanITCase.java |  16 +-
 .../stream/jsonplan/UnionJsonPlanITCase.java       |   4 +-
 .../testExpand.out}                                | 646 ++++++++++++---------
 11 files changed, 512 insertions(+), 325 deletions(-)
 copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{LimitJsonPlanTest.java => ExpandJsonPlanTest.java} (62%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/ExpandJsonPlanITCase.java
 copy flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupAggregateJsonPlanTest_jsonplan/testSimpleAggWithoutGroupBy[isMiniBatchEnabled=true].out => ExpandJsonPlanTest_jsonplan/testExpand.out} (58%)