You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/09/19 20:42:35 UTC
[08/11] storm git commit: STORM-1837: Wrap throwable in
RuntimeException before throwing from Runnable
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 <st...@gmail.com>
Authored: Mon Sep 19 18:28:55 2016 +0200
Committer: Stig Rohde D�ssing <st...@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);