[jira] [Commented] (STORM-329) Add Option to Config Message handling strategy when connection timeout

2014-11-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206145#comment-14206145 ] ASF GitHub Bot commented on STORM-329: -- Github user tedxia commented on the pull reque

[GitHub] storm pull request: STORM-329 : buffer message in client and recon...

2014-11-11 Thread tedxia
Github user tedxia commented on the pull request: https://github.com/apache/storm/pull/268#issuecomment-62516293 @clockfly --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enable

[GitHub] storm pull request: STORM-552:add new config storm.messaging.netty...

2014-11-11 Thread caofangkun
GitHub user caofangkun opened a pull request: https://github.com/apache/storm/pull/311 STORM-552:add new config storm.messaging.netty.backlog,default value 500 STORM-552:add new config storm.messaging.netty.backlog,default value 500 You can merge this pull request into a Git reposit

[jira] [Commented] (STORM-552) add new config storm.messaging.netty.backlog

2014-11-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14206185#comment-14206185 ] ASF GitHub Bot commented on STORM-552: -- GitHub user caofangkun opened a pull request:

[jira] [Assigned] (STORM-243) Record version and revision information in builds

2014-11-11 Thread caofangkun (JIRA)
[ https://issues.apache.org/jira/browse/STORM-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caofangkun reassigned STORM-243: Assignee: caofangkun > Record version and revision information in builds >

[jira] [Assigned] (STORM-534) Store Nimbus Server Information in zookeeper path {storm.zookeeper.root}/nimbus

2014-11-11 Thread caofangkun (JIRA)
[ https://issues.apache.org/jira/browse/STORM-534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caofangkun reassigned STORM-534: Assignee: caofangkun > Store Nimbus Server Information in zookeeper path > {storm.zookeeper.root}/n

[jira] [Assigned] (STORM-532) Supervisor should restart worker immediately, if the worker process does not exist any more

2014-11-11 Thread caofangkun (JIRA)
[ https://issues.apache.org/jira/browse/STORM-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caofangkun reassigned STORM-532: Assignee: caofangkun > Supervisor should restart worker immediately, if the worker process does not

[jira] [Assigned] (STORM-176) UI will lead to wrong url when running storm on yarn

2014-11-11 Thread caofangkun (JIRA)
[ https://issues.apache.org/jira/browse/STORM-176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caofangkun reassigned STORM-176: Assignee: caofangkun > UI will lead to wrong url when running storm on yarn > -

join and in-bolt caching

2014-11-11 Thread clay teahouse
Hello All, I need to 1) Look up some values from a source and cache them in a bolt 2) Filter a second stream based on the looked up values in (1). Example: 1) Area Codes = 712, 915 -- these area codes might change from time to time 2) People living in different addresses Emit: People leaving in a

Re: Enquiry regarding a project on @stormprocessor

2014-11-11 Thread Abhishek Bhattacharjee
First of all I apologise for the late response. I'll try to answer the questions one by one. > Is Redis for skipping completed tuples when root tuple is replayed, or > > continue processing tuple from last state? It doesn't skip the fully processed tuples it also stores them so that we have a bac

[GitHub] storm pull request: STORM-456:Storm UI cannot navigate to topology...

2014-11-11 Thread NareshKosgi
Github user NareshKosgi commented on the pull request: https://github.com/apache/storm/pull/303#issuecomment-62625740 Turns out this was just a simple change. Just needed to add url decode function. Updated the PR --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (STORM-456) Storm UI: cannot navigate to topology page when name contains spaces

2014-11-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207118#comment-14207118 ] ASF GitHub Bot commented on STORM-456: -- Github user NareshKosgi commented on the pull

[GitHub] storm pull request: STORM-456:Storm UI cannot navigate to topology...

2014-11-11 Thread Parth-Brahmbhatt
Github user Parth-Brahmbhatt commented on the pull request: https://github.com/apache/storm/pull/303#issuecomment-62628045 Have you tested with some other topologies, We were doing decoding before but it was removed because ring already decodes it before calling this function. Try a t

[jira] [Commented] (STORM-456) Storm UI: cannot navigate to topology page when name contains spaces

2014-11-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207143#comment-14207143 ] ASF GitHub Bot commented on STORM-456: -- Github user Parth-Brahmbhatt commented on the

Re: Enquiry regarding a project on @stormprocessor

2014-11-11 Thread 임정택
Benchmarks from various scenario is very important because high probabilities of failing tuples is not normal situation. If it only covers with specific situation, I think it needs to be more general. I hope to see your future plan about this. I love this concepts but it forces to have additional

[jira] [Commented] (STORM-350) Update disruptor to latest version (3.2.1)

2014-11-11 Thread Sean Zhong (JIRA)
[ https://issues.apache.org/jira/browse/STORM-350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207723#comment-14207723 ] Sean Zhong commented on STORM-350: -- The storm-benchmark-0.1.0-jar-with-dependencies.jar is

[jira] [Comment Edited] (STORM-350) Update disruptor to latest version (3.2.1)

2014-11-11 Thread Sean Zhong (JIRA)
[ https://issues.apache.org/jira/browse/STORM-350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14207723#comment-14207723 ] Sean Zhong edited comment on STORM-350 at 11/12/14 5:56 AM: The