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

HADOOP-14966. Handle JDK-8071638 for hadoop-common. Contributed by Bibin A Chundatt.

Browse Source
This commit is contained in:
Naganarasimha 2017-10-23 23:41:38 +05:30
parent 4b00c9a47f
commit 6b8122458e
1 changed files with 6 additions and 4 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

@ -40,14 +40,16 @@ static void logThrowableFromAfterExecute(Runnable r, Throwable t) {
//For additional information, see: https://docs.oracle
// .com/javase/7/docs/api/java/util/concurrent/ThreadPoolExecutor
// .html#afterExecute(java.lang.Runnable,%20java.lang.Throwable) .
// .html#afterExecute(java.lang.Runnable,%20java.lang.Throwable)
if (t == null && r instanceof Future<?>) {
// Handle JDK-8071638
if (t == null && r instanceof Future<?> && ((Future<?>) r).isDone()) {
try {
((Future<?>) r).get();
} catch (ExecutionException ee) {
LOG.warn("Execution exception when running task in " +
Thread.currentThread().getName());
LOG.warn(
"Execution exception when running task in " + Thread.currentThread()
.getName());
t = ee.getCause();
} catch (InterruptedException ie) {
LOG.warn("Thread (" + Thread.currentThread() + ") interrupted: ", ie);