[
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) <[email protected]>
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)
