[
https://issues.apache.org/jira/browse/STORM-543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Devang updated STORM-543:
-------------------------
Description:
Storm failing all input messages (although successfully processed) post
restarting worker on the same supervisor slot.
Steps to simulate the behaviour,
1. Run topology(spout as single instance and multiple instances of bolts)
on multiple workers.
2. Identify the slot on which the single spout instance is running (from STORM
UI) and kill it (using kill -9)
3. See if the supervisor started the worker on the same supervisor port. If not
then repeat step 2 untill you get supervisor on the same slot as previous one.
4. Pump in a message into the topology.
5. You will see message being processed successfully but acker failing the
tuple after the message times out (defaults to 30 secs).
was:
Steps to simulate the behaviour,
1. Run topology(spout as single instance and multiple instances of bolts)
on multiple workers.
2. Identify the slot on which the single spout instance is running (from STORM
UI) and kill it (using kill -9)
3. See if the supervisor started the worker on the same supervisor port. If not
then repeat step 2 untill you get supervisor on the same slot as previous one.
4. Pump in a message into the topology.
5. You will see message being processed successfully but acker failing the
tuple after the message times out (defaults to 30 secs).
Summary: Storm failing all input messages (although successfully
processed) post restarting worker on the same supervisor slot (was: Storm
failing all input messages (although successfully processed) post restarting on
the same supervisor slot)
> Storm failing all input messages (although successfully processed) post
> restarting worker on the same supervisor slot
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-543
> URL: https://issues.apache.org/jira/browse/STORM-543
> Project: Apache Storm
> Issue Type: Bug
> Affects Versions: 0.9.2-incubating
> Reporter: Devang
> Attachments: acker_bad_case.txt, acker_good_case.txt
>
>
> Storm failing all input messages (although successfully processed) post
> restarting worker on the same supervisor slot.
> Steps to simulate the behaviour,
> 1. Run topology(spout as single instance and multiple instances of bolts)
> on multiple workers.
> 2. Identify the slot on which the single spout instance is running (from
> STORM UI) and kill it (using kill -9)
> 3. See if the supervisor started the worker on the same supervisor port. If
> not then repeat step 2 untill you get supervisor on the same slot as previous
> one.
> 4. Pump in a message into the topology.
> 5. You will see message being processed successfully but acker failing the
> tuple after the message times out (defaults to 30 secs).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
