From e6d154d08a353a268d497fa893cac5f21670c639 Mon Sep 17 00:00:00 2001 From: godfreyhe Date: Wed, 19 Apr 2017 19:43:25 +0800 Subject: [PATCH] [FLINK-6327] [table] Bug in CommonCalc's estimateRowCount() method --- .../scala/org/apache/flink/table/plan/nodes/CommonCalc.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 bc25140df725e..96a74704e6edb 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 }