Small UI Fix: fix max batches and record counts
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/63d79a1d Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/63d79a1d Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/63d79a1d Branch: refs/heads/master Commit: 63d79a1d205c4be40cdf773e2b5c89869e284463 Parents: 208d511 Author: Steven Phillips <[email protected]> Authored: Sat Jun 21 22:38:14 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Wed Jun 25 09:10:12 2014 -0700 ---------------------------------------------------------------------- .../apache/drill/exec/server/rest/ProfileWrapper.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/63d79a1d/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/ProfileWrapper.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/ProfileWrapper.java b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/ProfileWrapper.java index c6cd250..dcb7a45 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/ProfileWrapper.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/ProfileWrapper.java @@ -119,10 +119,16 @@ public class ProfileWrapper { ArrayList<OperatorProfile> ops = new ArrayList<OperatorProfile>(m.getOperatorProfileList()); long biggestIncomingRecords = 0; long biggestBatches = 0; - - for (StreamProfile sp : ops.get(0).getInputProfileList()) { - biggestIncomingRecords += sp.getRecords(); - biggestBatches += sp.getBatches(); + + for (OperatorProfile op : ops) { + long incomingRecords = 0; + long batches = 0; + for (StreamProfile sp : op.getInputProfileList()) { + incomingRecords += sp.getRecords(); + batches += sp.getBatches(); + } + biggestIncomingRecords = Math.max(biggestIncomingRecords, incomingRecords); + biggestBatches = Math.max(biggestBatches, batches); } builder.appendInteger(m.getMinorFragmentId(), null);
