This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c7beb3f6f43e6e2dd969b916bf72bb698cf18a83 Author: Timo Walther <[email protected]> AuthorDate: Mon Jul 13 14:31:59 2020 +0200 [hotfix][table-planner-blink] Fix row size estimation for structured types --- .../org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala index d3fa169..c4debe0 100644 --- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala +++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala @@ -390,7 +390,7 @@ object FlinkRelMdSize { BuiltInMethod.AVERAGE_ROW_SIZE.method) def averageTypeValueSize(t: RelDataType): JDouble = t.getSqlTypeName match { - case SqlTypeName.ROW => + case SqlTypeName.ROW | SqlTypeName.STRUCTURED => estimateRowSize(t) case SqlTypeName.ARRAY => // 16 is an arbitrary estimate
