diff --git a/storm-core/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java b/storm-core/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java index 54736e50b2..bab7f62743 100644 --- a/storm-core/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java +++ b/storm-core/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java @@ -41,8 +41,7 @@ public void uncaughtException(Thread t, Throwable e) { if (Utils.exceptionCauseIsInstanceOf(InterruptedException.class, e) || Utils.exceptionCauseIsInstanceOf(java.io.InterruptedIOException.class, e)) { LOG.info("Got interrupted exception shutting thread down..."); - } else { - suicideFn.run(); } + suicideFn.run(); } }