Re: Question About Backtype

I think you have written your code using older version of Storm. backtype.storm do not exists in Storm 1.0.2, packages have moved. So you have have to use a storm version like 0.X.Y or just reimport packages in java code. Thanks Ravi. On Sat, Oct 8, 2016 at 2:23 AM, Davis Liang

Re: [DISCUSS] Provision for dead-letter topic in storm

Yes good idea, would love to have this functionality of passing some user defined data from bolt to spout on failures. Ravi On 27 Sep 2016 10:05 p.m., "Kyle Nusbaum" wrote: > It seems to me that this can be solved by allowing a user to attach some > arbitrary

Re: How to debug spout failures

Your tuple may be timing out, try increasing tuple timeout and also check ur setting of max pending tuple, you may not want unlimited tuple going through ur pipeline. Ravi. On 11 Sep 2016 7:09 p.m., "pradeep s" wrote: Hi, I have a storm topology running in storm

Re: AW: Use only latest values

gt; Regards, > Daniela > > > 2016-04-11 13:16 GMT+02:00 Ravi Sharma <ping2r...@gmail.com>: > > > Hi Daniel, > > > > What about creating your Redis Key in format MMDDHHmm_DeviceId or may > > be just HHmm_DeviceId > > > > i.e. > > 20

Re: AW: Use only latest values

Hi Daniel, What about creating your Redis Key in format MMDDHHmm_DeviceId or may be just HHmm_DeviceId i.e. 201604111213_A or 1213_A and give the key expiry time as 2 minutes. i assume you dont care about past data. Now whenevr a new value come set this key Value (MMDDHHmm_DeviceId or

Re: [DISCUSS] Java REST Framework adoption

spring boot + Ravi On Tue, Feb 23, 2016 at 3:16 PM, Ankur Garg wrote: > How about using Spring Boot & Jersey for writing this . Spring Boot will > give us packaged jar which once executed will bring up its own embedded > server (Jetty or Tomcat or some other ) .

Re: Does Storm work with Spring

> serializable and cannot be passed like above . >> >> So the problem is only to make this context available once per jvm . >> Hence I thought I will wrap it under a singleton and make this available to >> all spouts and bolts per jvm. >> >> Once I have this

Re: Does Storm work with Spring

nce topology gets submitted to run in a >> distributed cluster , I can initialize my context there and someway they >> are available to all Spouts and Bolts ..Basically some shared location >> where my application Context can be initialized (once and only once) and >> this contex

Re: Multiple Spouts in Same topology or Topology per spout

h One topology with multiple spouts ...What > if something goes wrong in One spout or its associated bolts .. Does it > impact other Spout as well? > > Thanks > Ankur > > On Sun, Oct 11, 2015 at 10:21 PM, Ravi Sharma <ping2r...@gmail.com> wrote: > >>

Re: Multiple Spouts in Same topology or Topology per spout

No 100% right ansers , u will have to test and see what will fit.. persoanlly i wud suggest Multiple spouts in one Topology and if you have N node where topology will be running then each Spout(reading from one queue) shud run N times in parallel. if 2 Queues and say 4 Nodes then one topolgy 4

Re: Does Storm work with Spring

Bolts and Spouts are created by Storm and not known to Spring Context. You need to manually add them to SpringContext, there are few methods available i.e. SpringContext.getContext().getAutowireCapableBeanFactory().autowireBeanProperties(this, AutowireCapableBeanFactory.AUTOWIRE_AUTODETECT,

Re: Does Storm work with Spring

; Hi Ravi , > > Thanks for your reply . I am using annotation based configuration and using > Spring Boot. > > Any idea how to do it using annotations ? > > > > On Tue, Sep 29, 2015 at 6:41 PM, Ravi Sharma <ping2r...@gmail.com> wrote: > > > Bolts and Spouts are crea

Re: Block spout

Hi Pradeep, It seems you want to send one tuple from spout to Bolt then bolt will write it to a file and some other cosumer/bolt will read from file. And while consumer reading, other tuple can be received by bolt and may write more content on the same file. is this right? if yes then continue