You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/06/17 02:09:14 UTC
[4/6] git commit: Minor fix for displayed estimates.
Minor fix for displayed estimates.
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/229754d2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/229754d2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/229754d2
Branch: refs/heads/master
Commit: 229754d20076fd24f97c3c0b87cbf18828de8e08
Parents: 708426b
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Jun 13 16:54:42 2014 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Jun 17 02:07:37 2014 +0200
----------------------------------------------------------------------
.../main/java/eu/stratosphere/compiler/dag/OptimizerNode.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/229754d2/stratosphere-compiler/src/main/java/eu/stratosphere/compiler/dag/OptimizerNode.java
----------------------------------------------------------------------
diff --git a/stratosphere-compiler/src/main/java/eu/stratosphere/compiler/dag/OptimizerNode.java b/stratosphere-compiler/src/main/java/eu/stratosphere/compiler/dag/OptimizerNode.java
index f2a9053..70471c1 100644
--- a/stratosphere-compiler/src/main/java/eu/stratosphere/compiler/dag/OptimizerNode.java
+++ b/stratosphere-compiler/src/main/java/eu/stratosphere/compiler/dag/OptimizerNode.java
@@ -630,6 +630,13 @@ public abstract class OptimizerNode implements Visitable<OptimizerNode>, Estimat
// let every operator do its computation
computeOperatorSpecificDefaultEstimates(statistics);
+ if (this.estimatedOutputSize < 0) {
+ this.estimatedOutputSize = -1;
+ }
+ if (this.estimatedNumRecords < 0) {
+ this.estimatedNumRecords = -1;
+ }
+
// overwrite default estimates with hints, if given
if (getPactContract() == null || getPactContract().getCompilerHints() == null) {
return ;