You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "James Xu (JIRA)" <ji...@apache.org> on 2013/12/14 07:23:06 UTC

[jira] [Created] (STORM-73) TridentTopology with a RichSpout and tuples that fail

James Xu created STORM-73:
-----------------------------

             Summary: TridentTopology with a RichSpout and tuples that fail
                 Key: STORM-73
                 URL: https://issues.apache.org/jira/browse/STORM-73
             Project: Apache Storm (Incubating)
          Issue Type: Bug
            Reporter: James Xu
            Priority: Minor


https://github.com/nathanmarz/storm/issues/323

Please see the following gist for a testcase: https://gist.github.com/3679478

Tested this with 0.8.1

What this Spout does is keep a counter for the tuples it emits and splits them into sequences. The the ack() and fail() methods expect that they receive exactly the number of ack or fail calls you would expect as emited for each sequence.

But watching the console, after around 13 sequences:

Acking sequence: 0
Acking sequence: 1
Acking sequence: 2
Acking sequence: 3
Acking sequence: 4
Acking sequence: 5
Acking sequence: 6
Acking sequence: 7
Acking sequence: 8
Acking sequence: 9
Acking sequence: 10
Acking sequence: 11
Acking sequence: 12
Acking sequence: 13
Failing sequence: 15
Some sequence didn't fail completly!! {14=396}
Failing sequence: 16
Some sequence didn't fail completly!! {14=396}
Failing sequence: 17

etc... etc.. Keeps failing from now on

-----------
barrywhart: This sounds very similar to a problem we were having last week on 0.8.0 on a conventional topology (non-Trident) written in Python. The spout would hang forever after about 100 messages.

In our case we were able to downgrade to 0.7.4, and it has been working fine since.



--
This message was sent by Atlassian JIRA
(v6.1.4#6159)