TEZ-3649. AsyncHttpConnection should add StopWatch start (Fei Hui via rbalamohan)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/518deb6c Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/518deb6c Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/518deb6c Branch: refs/heads/TEZ-1190 Commit: 518deb6c2ffba7db9af770ce0b5b248409d56aff Parents: 1b1eb1d Author: Rajesh Balamohan <[email protected]> Authored: Mon Mar 6 14:30:50 2017 +0530 Committer: Rajesh Balamohan <[email protected]> Committed: Mon Mar 6 14:30:50 2017 +0530 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../java/org/apache/tez/http/async/netty/AsyncHttpConnection.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/518deb6c/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 763acd8..f90a29e 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES ALL CHANGES: + TEZ-3649. AsyncHttpConnection should add StopWatch start. TEZ-3647. Add a setting which lets Tez determine Xmx. TEZ-3644. Cleanup container list stored in AMNode. TEZ-3646. IFile.Writer has an extra output stream flush call http://git-wip-us.apache.org/repos/asf/tez/blob/518deb6c/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java ---------------------------------------------------------------------- diff --git a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java b/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java index 5adfc3c..735bb46 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/AsyncHttpConnection.java @@ -176,6 +176,7 @@ public class AsyncHttpConnection extends BaseHttpConnection { } public void validate() throws IOException { + stopWatch.reset().start(); // get the shuffle version if (!ShuffleHeader.DEFAULT_HTTP_HEADER_NAME .equals(response.getHeader(ShuffleHeader.HTTP_HEADER_NAME))
