Return-Path: X-Original-To: apmail-streams-dev-archive@minotaur.apache.org Delivered-To: apmail-streams-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A506618446 for ; Fri, 19 Jun 2015 20:25:29 +0000 (UTC) Received: (qmail 78070 invoked by uid 500); 19 Jun 2015 20:25:29 -0000 Delivered-To: apmail-streams-dev-archive@streams.apache.org Received: (qmail 78027 invoked by uid 500); 19 Jun 2015 20:25:29 -0000 Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list dev@streams.incubator.apache.org Received: (qmail 78016 invoked by uid 99); 19 Jun 2015 20:25:29 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Jun 2015 20:25:29 +0000 X-ASF-Spam-Status: No, hits=-2000.4 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Fri, 19 Jun 2015 20:23:19 +0000 Received: (qmail 77408 invoked by uid 99); 19 Jun 2015 20:25:01 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Jun 2015 20:25:01 +0000 Date: Fri, 19 Jun 2015 20:25:01 +0000 (UTC) From: "Steve Blackmon (JIRA)" To: dev@streams.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Assigned] (STREAMS-311) TwitterUserInformationProvider stalls with > 20 items provided MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/STREAMS-311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steve Blackmon reassigned STREAMS-311: -------------------------------------- Assignee: Steve Blackmon > 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 > Assignee: Steve Blackmon > Fix For: 0.3 > > > 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)