big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source 
Downgrading warn logs to debug in case of InterruptedException

Contributed By: Mukund Thakur
This commit is contained in:
Mukund Thakur 2022-01-06 10:54:27 +05:30
parent 7dd8e900f8
commit 60c1c6d93c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java
View File

@ -47,12 +47,12 @@ static void logThrowableFromAfterExecute(Runnable r, Throwable t) {
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 @@ static void logThrowableFromAfterExecute(Runnable r, Throwable t) {
}
if (t != null) {
LOG.warn("Caught exception in thread " + Thread
.currentThread().getName() + ": ", t);
LOG.warn("Caught exception in thread {} + : ", Thread
.currentThread().getName(), t);
}
}