[jira] [Commented] (STREAMS-311) TwitterUserInformationProvider stalls with > 20 items provided

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/STREAMS-311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14534852#comment-14534852 ] 

ASF GitHub Bot commented on STREAMS-311:
----------------------------------------

GitHub user steveblackmon opened a pull request:

    https://github.com/apache/incubator-streams/pull/217

    resolves STREAMS-311 #311

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/steveblackmon/incubator-streams STREAMS-311

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/incubator-streams/pull/217.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 #217
    
----
commit 7a21d6682dc811f08e1d5f0341c86bd0ae0f3afe
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Date:   2015-05-08T16:41:41Z

    resolves STREAMS-311 #311

----


> TwitterUserInformationProvider stalls with > 20 items provided
> --------------------------------------------------------------
>
>                 Key: STREAMS-311
>                 URL: https://issues.apache.org/jira/browse/STREAMS-311
>             Project: Streams
>          Issue Type: Bug
>            Reporter: Steve Blackmon
>
> The way parallelism is handled in TwitterUserInformationProvider can cause the provider to stall when more threads are created than the size of the execution service queue which is hard-coded to twenty.
> The size of the execution service queue should equal the number of threads to ensure that startStream() does not block trying to add more threads, because until startStream() completes the local runtime does not poll readCurrent().



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)