Repository: hadoop Updated Branches: refs/heads/branch-2 c0e061b41 -> 8b31ff6db
YARN-6294. ATS client should better handle Socket closed case. Contributed by Li Lu. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8b31ff6d Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8b31ff6d Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8b31ff6d Branch: refs/heads/branch-2 Commit: 8b31ff6dba9b189dd3bae7076daafd4455bc450e Parents: c0e061b Author: Junping Du <[email protected]> Authored: Wed Mar 15 11:49:51 2017 -0700 Committer: Junping Du <[email protected]> Committed: Wed Mar 15 11:49:51 2017 -0700 ---------------------------------------------------------------------- .../apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/8b31ff6d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java index dd165d4..969f78a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/api/impl/TimelineClientImpl.java @@ -24,6 +24,7 @@ import java.lang.reflect.UndeclaredThrowableException; import java.net.ConnectException; import java.net.HttpURLConnection; import java.net.InetSocketAddress; +import java.net.SocketException; import java.net.SocketTimeoutException; import java.net.URI; import java.net.URL; @@ -243,7 +244,8 @@ public class TimelineClientImpl extends TimelineClient { // Only retry on connection exceptions return (e instanceof ClientHandlerException) && (e.getCause() instanceof ConnectException || - e.getCause() instanceof SocketTimeoutException); + e.getCause() instanceof SocketTimeoutException || + e.getCause() instanceof SocketException); } }; try { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
