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 2019/07/22 08:50:57 UTC
[flink] branch master updated (6961d9b -> 61d2525)

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 6961d9b  [FLINK-13284][table-planner-blink] Correct some builtin functions' return type inference in Blink planner
     add e53a85d  [FLINK-13304][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow
     add bc2fd31  [FLINK-13322][table-runtime-blink] Fix serializer snapshot recovery in BaseArray and BaseMap serializers
     add 61d2525  [FLINK-13323][table-runtime-blink] Add tests for complex data formats

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/table/dataformat/NestedRow.java   |  12 +-
 .../flink/table/types/InternalSerializers.java     |   4 +-
 .../flink/table/typeutils/BaseArraySerializer.java |  26 +-
 .../flink/table/typeutils/BaseMapSerializer.java   |  59 ++-
 .../apache/flink/table/dataformat/BaseRowTest.java |   3 +-
 .../flink/table/dataformat/BinaryArrayTest.java    |   4 +-
 .../flink/table/dataformat/BinaryRowTest.java      | 539 ++++++++++++++++++++-
 .../flink/table/dataformat/DataFormatTestUtil.java | 139 ++++++
 .../apache/flink/table/dataformat/DecimalTest.java |   8 +
 .../flink/table/dataformat/NestedRowTest.java      | 162 +++++++
 .../table/typeutils/BaseArraySerializerTest.java   |  57 +++
 .../table/typeutils/BaseMapSerializerTest.java     |  66 ++-
 .../flink/table/typeutils/SerializerTestUtil.java  | 143 ++++++
 .../apache/flink/table/util/SegmentsUtilTest.java  | 149 +++++-
 14 files changed, 1330 insertions(+), 41 deletions(-)
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/DataFormatTestUtil.java
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/NestedRowTest.java
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/typeutils/SerializerTestUtil.java