[
https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15365574#comment-15365574
]
ASF GitHub Bot commented on STORM-1939:
---------------------------------------
GitHub user HeartSaVioR opened a pull request:
https://github.com/apache/storm/pull/1543
STORM-1939 Ignore InterruptedException on ShellBoltMessageQueue
InterruptedException makes false alarm for ShellBolt shutting down.
Since it's likely throwing InterruptedException when ShellBolt is shutting
down, so we're ok to just consume that and continue.
Please see https://issues.apache.org/jira/browse/STORM-1939 for more
details.
It should be applied to master, 1.x, 1.0.x branches.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/HeartSaVioR/storm STORM-1939
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1543.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1543
----
commit 675e45547c2a27bcab4fcd1ce95ab51bc68cfbbe
Author: Jungtaek Lim <[email protected]>
Date: 2016-07-07T03:58:37Z
STORM-1939 Ignore InterruptedException on ShellBoltMessageQueue
* Since it's likely throwing InterruptedException when ShellBolt is
shutting down
* so we're ok to just consume that and continue
----
> Frequent InterruptedException raised by ShellBoltMessageQueue.poll
> ------------------------------------------------------------------
>
> Key: STORM-1939
> URL: https://issues.apache.org/jira/browse/STORM-1939
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
> Affects Versions: 1.0.1
> Reporter: Dan Blanchard
> Assignee: Jungtaek Lim
>
> We've recently started testing out Storm 1.0.1 on a beta cluster we have
> setup, and we've noticed that one of our topologies frequently crashes with
> the following stack trace:
> {code:java}
> java.lang.InterruptedException
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2017)
>
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2095)
>
> at
> org.apache.storm.utils.ShellBoltMessageQueue.poll(ShellBoltMessageQueue.java:104)
>
> at
> org.apache.storm.task.ShellBolt$BoltWriterRunnable.run(ShellBolt.java:383)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> We're using a lot of Python components with streamparse 3.0.0.dev3 and are
> using the [MessagePackSerializer that was originally from
> pyleus|https://github.com/YelpArchive/pyleus/blob/develop/topology_builder/src/main/java/com/yelp/pyleus/serializer/MessagePackSerializer.java]
> with all the instances of "backtype" replaced with "org.apache".
> Aside from the frequent bolt deaths from these exceptions, things seem to
> work, so I'm not sure what's going on here.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
