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);
