Re: Introduce lag into a topology spout to process the events with a delay.

2017-02-23 Thread Sandeep Samudrala
riting the stream A into some key value store and then perform enriching .* > > *Obviously , I am making lot of assumptions here since they are not > mentioned in the question and I am not aware of full context of the problem > too . * > > *Hope this helps* > *Ankur* > > On W

Re: Introduce lag into a topology spout to process the events with a delay.

2017-02-21 Thread Sandeep Samudrala
Mq etc.) with some spout (as part of > some topology) reading from them . Please confirm . > > Thanks > Ankur > > On Tue, 21 Feb 2017 at 15:28 Sandeep Samudrala <sandys...@gmail.com> > wrote: > >> Hello, >> I have two streams A and B. I need to enrich events c

Introduce lag into a topology spout to process the events with a delay.

2017-02-21 Thread Sandeep Samudrala
Hello, I have two streams A and B. I need to enrich events coming from stream B with events coming from A and I store events coming from A in a key-value store to enrich events from B. Events that doesn't get enriched are sent to a deferred queue(kafka stream) and are read back later. Most of

Storm 0.9.4 on yarn

2015-04-16 Thread Sandeep Samudrala
I was running storm on yarn using https://github.com/yahoo/storm-yarn; but yahoo storm on yarn was integrated with storm-0.9.0-wip21, which is bit older version. We tried patching storm 0.9.4 with storm-on-yarn and then deploy storm on yarn cluster.The Storm UI shows up with. Page not found Is