Repository: flink Updated Branches: refs/heads/master 59cf7032f -> 52f8b33e5
[FLINK-6327] [table] Bug in CommonCalc's estimateRowCount() method This closes #3740. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/52f8b33e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/52f8b33e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/52f8b33e Branch: refs/heads/master Commit: 52f8b33e5c932157da18a7c53ce75a80d169f95e Parents: 59cf703 Author: godfreyhe <godfre...@163.com> Authored: Wed Apr 19 19:43:25 2017 +0800 Committer: Kurt Young <k...@apache.org> Committed: Thu Apr 20 09:00:00 2017 +0800 ---------------------------------------------------------------------- .../main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/52f8b33e/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala index bc25140..96a7470 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala @@ -177,7 +177,7 @@ trait CommonCalc { if (calcProgram.getCondition != null) { // we reduce the result card to push filters down - (rowCnt * 0.75).min(1.0) + (rowCnt * 0.75).max(1.0) } else { rowCnt }
