flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/6] git commit: Minor fix for displayed estimates.
Date Tue, 17 Jun 2014 00:09:14 GMT
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 <sewen@apache.org>
Authored: Fri Jun 13 16:54:42 2014 +0200
Committer: Stephan Ewen <sewen@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 ;


Mime
View raw message