Repository: flink Updated Branches: refs/heads/master c4536e8a2 -> 35050bbf2
[hotfix] [table] Remove typo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/35050bbf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/35050bbf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/35050bbf Branch: refs/heads/master Commit: 35050bbf227801f59acf265c1a42ed393d19b28a Parents: c4536e8 Author: twalthr <[email protected]> Authored: Wed Jan 11 14:57:15 2017 +0100 Committer: twalthr <[email protected]> Committed: Wed Jan 11 14:57:15 2017 +0100 ---------------------------------------------------------------------- .../main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/35050bbf/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala index 0681401..a7765d1 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala @@ -107,7 +107,7 @@ trait FlinkRel { val fieldList = rowType.getFieldList fieldList.map(_.getType).foldLeft(0.0) { (s, t) => - git s + estimateDataTypeSize(t) + s + estimateDataTypeSize(t) } }
