You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2018/02/20 05:30:00 UTC
[jira] [Commented] (STORM-2958) Use new wait strategies for Spout
as well
[ https://issues.apache.org/jira/browse/STORM-2958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16369735#comment-16369735 ]
Jungtaek Lim commented on STORM-2958:
-------------------------------------
[~roshan_naik]
I filed new issue (STORM-2964) about deprecating old spout model in 1.x version line. I'd be really appreciated if you could take up. Please let me know if you are busy with other tasks. I'll be happy to take up.
> Use new wait strategies for Spout as well
> -----------------------------------------
>
> Key: STORM-2958
> URL: https://issues.apache.org/jira/browse/STORM-2958
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-client
> Affects Versions: 2.0.0
> Reporter: Roshan Naik
> Assignee: Roshan Naik
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.0.0
>
> Time Spent: 40m
> Remaining Estimate: 0h
>
> STORM-2306 introduced a new configurable wait strategy system for these situations
> * BackPressure Wait (used by spout & bolt)
> * No incoming data (used by bolt)
> There is another wait situation in the spout when there are no emits generated in a nextTuple() or if max.spout.pending has been reached. This Jira is to transition the spout wait strategy from the old model to the new model. Thereby we have a uniform model for dealing with wait strategies.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)