Repository: tez Updated Branches: refs/heads/branch-0.7 37074a92e -> 4d44c5854
postfix Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/81efeffe Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/81efeffe Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/81efeffe Branch: refs/heads/branch-0.7 Commit: 81efeffef66174ad5acca06745ab9467fe7badde Parents: 17d5c18 Author: Bikas Saha <[email protected]> Authored: Fri Dec 11 14:46:53 2015 -0800 Committer: Bikas Saha <[email protected]> Committed: Fri Dec 11 17:23:28 2015 -0800 ---------------------------------------------------------------------- .../apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/81efeffe/tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java ---------------------------------------------------------------------- diff --git a/tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java b/tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java index e63d2a1..308579b 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/dag/library/vertexmanager/ShuffleVertexManager.java @@ -528,7 +528,6 @@ public class ShuffleVertexManager extends VertexManagerPlugin { throw new TezUncheckedException(e); } long sourceTaskOutputSize = proto.getOutputSize(); - numVertexManagerEventsReceived++; completedSourceTasksOutputSize += sourceTaskOutputSize; if (LOG.isDebugEnabled()) { LOG.debug("Received info of output size: " + sourceTaskOutputSize
