[FLINK-1150] Fix size estimate for FilterNode. Data size changes prop…

…ortional to cardinality. This closes apache#146
VonRosenchild · Oct 9, 2014 · 3eebaa8 · 3eebaa8
1 parent 986f25f
commit 3eebaa8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flink-compiler/src/main/java/org/apache/flink/compiler/dag/FilterNode.java b/flink-compiler/src/main/java/org/apache/flink/compiler/dag/FilterNode.java
@@ -64,5 +64,6 @@ protected List<OperatorDescriptorSingle> getPossibleProperties() {
  @Override
  protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics) {
  this.estimatedNumRecords = (long) (getPredecessorNode().getEstimatedNumRecords() * 0.5);
+ this.estimatedOutputSize = (long) (getPredecessorNode().getEstimatedOutputSize() * 0.5);
  }
 }