You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 19:43:46 UTC
[jira] [Commented] (STORM-996) netty-unit-tests/test-batch
demonstrates out-of-order delivery
[ https://issues.apache.org/jira/browse/STORM-996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14725756#comment-14725756 ]
ASF GitHub Bot commented on STORM-996:
--------------------------------------
GitHub user knusbaum opened a pull request:
https://github.com/apache/storm/pull/711
STORM-996: netty-unit-tests/test-batch demonstrates out-of-order delivery
Netty calls notifyInterestChanged which causes a race condition in flushMessages.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/knusbaum/incubator-storm STORM-996
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/711.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 #711
----
commit 11886c0c4c3aa2547b1ef571712bed83229dc4e4
Author: Kyle Nusbaum <ky...@gmail.com>
Date: 2015-09-01T17:13:05Z
Netty Fix.
commit 3783f4e6669d185d5a0fd42468347238350c2774
Author: Kyle Nusbaum <ky...@gmail.com>
Date: 2015-09-01T17:37:01Z
Whitespace
----
> netty-unit-tests/test-batch demonstrates out-of-order delivery
> --------------------------------------------------------------
>
> Key: STORM-996
> URL: https://issues.apache.org/jira/browse/STORM-996
> Project: Apache Storm
> Issue Type: Bug
> Affects Versions: 0.10.0
> Reporter: Derek Dagit
> Assignee: Kyle Nusbaum
> Priority: Blocker
> Attachments: storm-996-OrderedDownstreamThreadPoolExecutor-failed.txt.bz2
>
>
> backtype.storm.messaging.netty-unit-test/test-batch
> One example of output. Similar things happen sporadically and vary widely by number of failed assertions.
> Tuples are not just skewed, but actually seem to come in out-of-order.
> {quote}
> actual: (not (= "66040" "66041"))
> at: test_runner.clj:105
> expected: (= req_msg resp_msg)
> actual: (not (= "66041" "66042"))
> at: test_runner.clj:105
> expected: (= req_msg resp_msg)
> actual: (not (= "66042" "66040"))
> at: test_runner.clj:105
> {quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)