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

Posted to commits@flink.apache.org by tw...@apache.org on 2020/07/13 11:14:24 UTC

[flink] branch master updated (0fbea46 -> a028ba2)

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

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


    from 0fbea46  [FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastStateMigrationITCase to cover migration till release-1.11
     add a028ba2  [FLINK-18528][table] Update UNNEST to new type system

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/table/types/logical/RowType.java  |   8 +-
 .../flink/table/types/utils/DataTypeUtils.java     |   9 +
 .../functions/bridging/BridgingSqlFunction.java    |  35 ++++
 .../planner/plan/QueryOperationConverter.java      |  14 +-
 .../plan/rules/logical/LogicalUnnestRule.scala     |  89 +++-------
 .../planner/plan/utils/ExplodeFunctionUtil.scala   | 178 -------------------
 .../table/planner/plan/batch/sql/UnnestTest.xml    |  20 +--
 .../plan/rules/logical/LogicalUnnestRuleTest.xml   |  20 +--
 .../table/planner/plan/stream/sql/UnnestTest.xml   |  20 +--
 .../table/runtime/functions/SqlUnnestUtils.java    | 189 +++++++++++++++++++++
 10 files changed, 292 insertions(+), 290 deletions(-)
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/ExplodeFunctionUtil.scala
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlUnnestUtils.java