diff --git src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java index 3bc9ed9..cb3bc1e 100644 --- src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java +++ src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/concurrent/ExecutorHelper.java @@ -25,6 +25,7 @@ import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; +import java.util.concurrent.ScheduledFuture; /** Helper functions for Executors. */ public final class ExecutorHelper { @@ -42,7 +43,7 @@ static void logThrowableFromAfterExecute(Runnable r, Throwable t) { // .com/javase/7/docs/api/java/util/concurrent/ThreadPoolExecutor // .html#afterExecute(java.lang.Runnable,%20java.lang.Throwable) . - if (t == null && r instanceof Future) { + if (t == null && r instanceof Future && !(r instanceof ScheduledFuture)) { try { ((Future) r).get(); } catch (ExecutionException ee) {