Repository: storm
Updated Branches:
  refs/heads/master b8c52026f -> 74c31164d


STORM-2142 ReportErrorAndDie runs suicide function only when 
InterruptedException or InterruptedIOException is thrown

* There seems to be a small bug while porting


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/df67ade7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/df67ade7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/df67ade7

Branch: refs/heads/master
Commit: df67ade7ef58707c3142853eb1010283e730d78f
Parents: ce7ba75
Author: Jungtaek Lim <kabh...@gmail.com>
Authored: Mon Oct 10 14:18:14 2016 +0900
Committer: Jungtaek Lim <kabh...@gmail.com>
Committed: Mon Oct 10 14:18:14 2016 +0900

----------------------------------------------------------------------
 .../src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/df67ade7/storm-core/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java
----------------------------------------------------------------------
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 d326af1..54736e5 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,6 +41,7 @@ public class ReportErrorAndDie implements 
Thread.UncaughtExceptionHandler {
         if (Utils.exceptionCauseIsInstanceOf(InterruptedException.class, e)
                 || 
Utils.exceptionCauseIsInstanceOf(java.io.InterruptedIOException.class, e)) {
             LOG.info("Got interrupted exception shutting thread down...");
+        } else {
             suicideFn.run();
         }
     }

Reply via email to