Browse Source

HADOOP-18065. ExecutorHelper.logThrowableFromAfterExecute() is too noisy. (#3860)

Downgrading warn logs to debug in case of InterruptedException

Contributed By: Mukund Thakur
Mukund Thakur 3 years ago
parent
commit
da0a6ba1ce

+ 5 - 5
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java

@@ -47,12 +47,12 @@ public final class ExecutorHelper {
       try {
         ((Future<?>) r).get();
       } catch (ExecutionException ee) {
-        LOG.warn(
-            "Execution exception when running task in " + Thread.currentThread()
+        LOG.debug(
+            "Execution exception when running task in {}", Thread.currentThread()
                 .getName());
         t = ee.getCause();
       } catch (InterruptedException ie) {
-        LOG.warn("Thread (" + Thread.currentThread() + ") interrupted: ", ie);
+        LOG.debug("Thread ( {} ) interrupted: ", Thread.currentThread(), ie);
         Thread.currentThread().interrupt();
       } catch (Throwable throwable) {
         t = throwable;
@@ -60,8 +60,8 @@ public final class ExecutorHelper {
     }
 
     if (t != null) {
-      LOG.warn("Caught exception in thread " + Thread
-          .currentThread().getName() + ": ", t);
+      LOG.warn("Caught exception in thread {}  + : ", Thread
+              .currentThread().getName(), t);
     }
   }