Repository: hadoop Updated Branches: refs/heads/branch-2 7b2b6caf1 -> 7c3578ca1
YARN-6166. Unnecessary INFO logs in AMRMClientAsyncImpl$CallbackHandlerThread.run (Contributed by Grant Whiteheart via Daniel Templeton) (cherry picked from commit 1238fa71f8e62cecde6e2437d1b83ad3922295f8) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7c3578ca Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7c3578ca Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7c3578ca Branch: refs/heads/branch-2 Commit: 7c3578ca17fb4ff813f8c0c55f345e3e554f9be7 Parents: 7b2b6ca Author: Daniel Templeton <templ...@apache.org> Authored: Fri Feb 10 09:44:49 2017 -0800 Committer: Daniel Templeton <templ...@apache.org> Committed: Fri Feb 10 09:48:50 2017 -0800 ---------------------------------------------------------------------- .../hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7c3578ca/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java index bba6993..d040345 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java @@ -310,7 +310,8 @@ extends AMRMClientAsync<T> { try { object = responseQueue.take(); } catch (InterruptedException ex) { - LOG.info("Interrupted while waiting for queue", ex); + LOG.debug("Interrupted while waiting for queue", ex); + Thread.currentThread().interrupt(); continue; } if (object instanceof Throwable) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
