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/14 08:36:33 UTC
[flink] 02/04: [hotfix][table-planner-blink] Fix row size
estimation for structured types
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 <tw...@apache.org>
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