[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745845#comment-16745845
]
Roshan Naik commented on STORM-2359:
Yes indeed. It will be quite nice if JC Tools queues could
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745154#comment-16745154
]
Stig Rohde Døssing commented on STORM-2359:
---
Thanks, responded there.
Just to give an update
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744817#comment-16744817
]
Roshan Naik commented on STORM-2359:
[~Srdo] Fyi: Just posted the initial thoughts around Acker
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16741281#comment-16741281
]
Stig Rohde Døssing commented on STORM-2359:
---
{quote}
if a msg is in the inputQ or
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740143#comment-16740143
]
Roshan Naik commented on STORM-2359:
Got a chance to read through your posts more carefully again.
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739641#comment-16739641
]
Stig Rohde Døssing commented on STORM-2359:
---
I think it makes sense to open a WIP PR for
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739639#comment-16739639
]
Stig Rohde Døssing commented on STORM-2359:
---
I've been taking a look at the feasibility of
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730920#comment-16730920
]
Stig Rohde Døssing commented on STORM-2359:
---
The contents of the message is a list of longs
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730881#comment-16730881
]
Roshan Naik commented on STORM-2359:
I see your point about having the timeout logic in acker. It’s a
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730657#comment-16730657
]
Stig Rohde Døssing commented on STORM-2359:
---
I made a few more changes, mainly to remove the
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16726614#comment-16726614
]
Stig Rohde Døssing commented on STORM-2359:
---
{quote}Acker will be totally clueless if all acks
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16726414#comment-16726414
]
Roshan Naik commented on STORM-2359:
{quote}If we were to move timeouts entirely to the acker, there
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723067#comment-16723067
]
Stig Rohde Døssing commented on STORM-2359:
---
There's a branch implementing this at
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723070#comment-16723070
]
Stig Rohde Døssing commented on STORM-2359:
---
I will check what impact it has to reinsert tuples
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723055#comment-16723055
]
Stig Rohde Døssing commented on STORM-2359:
---
I've been taking a look at this, and have a
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16045442#comment-16045442
]
Stig Rohde Døssing commented on STORM-2359:
---
I think the reason it would be tough to move
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16045053#comment-16045053
]
Roshan Naik commented on STORM-2359:
{quote} The current implementation has a pending map in both the
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043409#comment-16043409
]
Stig Rohde Døssing commented on STORM-2359:
---
{quote}
The resets are managed internally by the
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16041851#comment-16041851
]
Roshan Naik commented on STORM-2359:
{quote} In order to reduce load on the spout, we should try to
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027906#comment-16027906
]
Stig Rohde Døssing commented on STORM-2359:
---
I thought a bit more about this.
Here are the
[
https://issues.apache.org/jira/browse/STORM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930644#comment-15930644
]
Stig Rohde Døssing commented on STORM-2359:
---
This is a great idea, we've also seen topologies
21 matches
Mail list logo
