From 1238fa71f8e62cecde6e2437d1b83ad3922295f8 Mon Sep 17 00:00:00 2001 From: Daniel Templeton Date: Fri, 10 Feb 2017 09:44:49 -0800 Subject: [PATCH] YARN-6166. Unnecessary INFO logs in AMRMClientAsyncImpl$CallbackHandlerThread.run (Contributed by Grant Whiteheart via Daniel Templeton) --- .../hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 3dd53d35542..3e72d3fbe7d 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 @@ -313,7 +313,8 @@ extends AMRMClientAsync { 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) {