STORM-1837: Wrap throwable in RuntimeException before throwing from Runnable


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

Branch: refs/heads/master
Commit: 70ecffc8b83ccdf8f99bd35dfb53e14ef3578fa6
Parents: 0264698
Author: Stig Rohde Døssing <stigdoess...@gmail.com>
Authored: Mon Sep 19 18:28:55 2016 +0200
Committer: Stig Rohde Døssing <stigdoess...@gmail.com>
Committed: Mon Sep 19 18:28:55 2016 +0200

----------------------------------------------------------------------
 storm-core/src/jvm/org/apache/storm/messaging/local/Context.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/70ecffc8/storm-core/src/jvm/org/apache/storm/messaging/local/Context.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/messaging/local/Context.java 
b/storm-core/src/jvm/org/apache/storm/messaging/local/Context.java
index 30c7936..83a8a99 100644
--- a/storm-core/src/jvm/org/apache/storm/messaging/local/Context.java
+++ b/storm-core/src/jvm/org/apache/storm/messaging/local/Context.java
@@ -110,7 +110,7 @@ public class Context implements IContext {
                         flushPending();
                     } catch (Throwable t) {
                         LOG.error("Uncaught throwable in pending message 
flusher thread, messages may be lost", t);
-                        throw t;
+                        throw new RuntimeException(t);
                     }
                 }
             }, 5, 5, TimeUnit.SECONDS);

Reply via email to