Small stats fix: add current Exchange to the parent fragment stat.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/8773f84b Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/8773f84b Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/8773f84b Branch: refs/heads/master Commit: 8773f84b7b8b238f9653b05607e153438a624777 Parents: 0c9d4eb Author: Aman Sinha <asi...@maprtech.com> Authored: Fri Jun 20 17:59:02 2014 -0700 Committer: Jacques Nadeau <jacq...@apache.org> Committed: Wed Jun 25 09:08:22 2014 -0700 ---------------------------------------------------------------------- .../exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/8773f84b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java index 168fd28..06b72f9 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/ExcessiveExchangeIdentifier.java @@ -45,6 +45,7 @@ public class ExcessiveExchangeIdentifier extends BasePrelVisitor<Prel, Excessive @Override public Prel visitExchange(ExchangePrel prel, MajorFragmentStat parent) throws RuntimeException { + parent.add(prel); MajorFragmentStat newFrag = new MajorFragmentStat(); Prel newChild = ((Prel) prel.getChild()).accept(this, newFrag);
