Re: [VOTE] Storm Logo Contest - Round 1

#11 - 3 pts. #1 - 2 pts. On Mon, May 19, 2014 at 3:17 PM, Binh Nguyen Van wrote: > #9 - 4 pts. > #8 - 2 pts. > > > On Mon, May 19, 2014 at 9:57 AM, wrote: > >> #11 - 3 pts >> #6- 2 pts >> >> Sent from Windows Mail >> >> *From:* Uditha Bandara Wijerathna >> *Sent:* ‎Sunday‎, ‎May‎ ‎18‎, ‎

Re: Kafka Spout 0.8-plus stops consuming messages after a while

I finally found the root cause. Turns out the spout was reading a message exceeded the max message size. After increasing the message size in SpoutConfig, it worked. It would have been nice if the Spout threw an error or exception in such cases. Jing On May 16, 2014, at 12:09 PM, "Tao, Jing

Re: [VOTE] Storm Logo Contest - Round 1

#9 - 4 pts. #8 - 2 pts. On Mon, May 19, 2014 at 9:57 AM, wrote: > #11 - 3 pts > #6- 2 pts > > Sent from Windows Mail > > *From:* Uditha Bandara Wijerathna > *Sent:* ‎Sunday‎, ‎May‎ ‎18‎, ‎2014 ‎4‎:‎28‎ ‎AM > *To:* user@storm.incubator.apache.org > *Cc:* d...@storm.incubator.apache.org > >

Re: [VOTE] Storm Logo Contest - Round 1

#11 - 3 pts #6- 2 pts Sent from Windows Mail From: Uditha Bandara Wijerathna Sent: ‎Sunday‎, ‎May‎ ‎18‎, ‎2014 ‎4‎:‎28‎ ‎AM To: user@storm.incubator.apache.org Cc: d...@storm.incubator.apache.org On Thu, May 15, 2014 at 9:58 PM, P. Taylor Goetz wrote: This is a call to vote

Re: Performance metrics in storm

Hi Michael, Is the graphite available on windows? On Sat, May 17, 2014 at 2:29 AM, Michael G. Noll < michael+st...@michael-noll.com> wrote: > To add to what Jason and Otis already shared, here is an article I wrote > a while back (shameless plug): > > > http://www.michael-noll.com/blog/2013/11/

Will bolt's finalize() be called if we rebalance to 0

I have a bolt that has loaded a native library thru JNI's loadlibrary(...). As my topology is running all the time, as I have a newer version of that OS's native library, is it possible to a) simply rebalance the bolt to '0' , b) then deploy the native library. c) If the bolt's finalize() method is

Re: Test timed out (5000ms)

Thank you. I will be better if this property can be configurable. *Pichkurov Sergey, Java Developer* On Mon, May 19, 2014 at 6:47 PM, Derek Dagit wrote: > https://github.com/apache/incubator-storm/blob/master/ > storm-core/src/clj/backtype/storm/testing.clj#L187 > > Corrected link. > > -- >

Re: Test timed out (5000ms)

https://github.com/apache/incubator-storm/blob/master/storm-core/src/clj/backtype/storm/testing.clj#L187 Corrected link. -- Derek On 5/19/14, 10:10, Sergey Pichkurov wrote: I think that 5 sec is not always enought for Spring init. Your link is not resolving. *Pichkurov Sergey, Java Developer

Re: Test timed out (5000ms)

I think that 5 sec is not always enought for Spring init. Your link is not resolving. *Pichkurov Sergey, Java Developer* On Mon, May 19, 2014 at 5:18 PM, Derek Dagit wrote: > https://git.corp.yahoo.com/storm/storm/blob/master- > security/storm-core/src/clj/backtype/storm/testing.clj#L167 > >

Re: Externalize storm.yaml file

Use soft links. Prasun Sent from Galaxy Nexus On May 14, 2014 6:50 AM, "Neha Jain" wrote: > Hello, > > > > I have created a storm cluster on Amazon EC2 machines. The requirement we > have is to save Storm configuration file to Amazon S3. > > There would be a bucket in S3 where storm config

Re: Storm with video/audio streams

No reason why you couldn't do it, but as far as I know it hasn't been done before. You can send any kind of serializable data into a topology. You'd probably need to emit frames from the spout. Michael Rose (@Xorlev ) Senior Platform Engineer, FullContact

Notify workers when a worker crashes

Hi, I have a trident topology built with storm.0.9.0.1. When a worker crashes, I need to inform the other workers of this crash and to do some computations after. Does trident include a mechanism to notify the workers and the associated partitions? Thanks, Florian Duros

Re: Test timed out (5000ms)

https://git.corp.yahoo.com/storm/storm/blob/master-security/storm-core/src/clj/backtype/storm/testing.clj#L167 Try changing this. The time-out was added to prevent the case when a test would hang indefinitely. Five seconds was thought to be more than enough time to let tests pass. If it need

Re: [VOTE] Storm Logo Contest - Round 1

#5 -3pt #6 -2pt 2014-05-19 14:25 GMT+01:00 Derek Dagit : > #1 - 1pt. > #2 - 1pt. > #9 - 2pts. > #10 - 1pts. > > There is a lot to like in these entries. It was tough to narrow it down. > -- > Derek > > > On 5/15/14, 11:28, P. Taylor Goetz wrote: > >> This is a call to vote on selecting the to

Re: [VOTE] Storm Logo Contest - Round 1

#1 - 1pt. #2 - 1pt. #9 - 2pts. #10 - 1pts. There is a lot to like in these entries. It was tough to narrow it down. -- Derek On 5/15/14, 11:28, P. Taylor Goetz wrote: This is a call to vote on selecting the top 3 Storm logos from the 11 entries received. This is the first of two rounds of vot

Re: [VOTE] Storm Logo Contest - Round 1

#1 - 5 pts Bryan Stone Staff Cloud Architect Cloud Platform Lead 6723 Odyssey Drive Huntsville, AL 35806 (256) 924-3976 // direct (256) 724-0113 // cell www.synapse-wireless.com On 5/15/14, 11:28 AM, "P. Taylor Goetz" wrote: >This is a call to vote on selec

Storm with video/audio streams

Hi, I just started playing around with storm a few days back. I worked with some basic examples using the twitter streaming api. I was wondering If storm can also be used with live video/audio streaming api ( the youtube streaming api for example). I wanted to develop a app which does somethin

How to catch exceptions from a Spout

Hi there, First of all, as this is my first message to the list, I'd like to thank you all for Storm, this project is impressive and is very interesting. I'm glad I found it for the new project I'm working on! It's a pleasure to learn how to master it. Here comes my first questions. I've built a

Does Esper work with Storm 0.9.x version

My application is using storm 0.9.0 version. I am trying to integrate Esper with it but it doesn't work with that. But when I tested Esper with storm 0.8.1 and 0.8.2 version, then it works fine. The example https://github.com/tomdz/storm-esper is also based on storm 0.8.1. Anyone have idea whether

Test timed out (5000ms)

Hello, Storm community. I trying to write unit test with storm.version :0.9.1-incubating storm-kafka-0.8-plus: 0.4.0 My topology have one Kafka spout and one storing bolt which has Spring inside(context initialized in prepare() method). When I running test with Testing.completeTopology(),

Understanding ACKing mechanism

I have a topology, that looks like *All Bolts emits Fields "id", "json"* *Spout emits only id* *All bolts/spout uses the stream _stream name while emitting* *Topology Definition* *==* builder.setSpout("citySpout", citySpout,10); builder.setBolt("impactBol

Re: [VOTE] Storm Logo Contest - Round 1

#9 - 3pts # 6 - 2pts Regards Laurent - Mail original - De: "P. Taylor Goetz" À: d...@storm.incubator.apache.org, user@storm.incubator.apache.org Envoyé: Jeudi 15 Mai 2014 18:28:05 Objet: [VOTE] Storm Logo Contest - Round 1 This is a call to vote on selecting the top 3 Storm lo

Re: [VOTE] Storm Logo Contest - Round 1

#9 : 3 pts #10: 2 pts On Thu, May 15, 2014 at 9:28 AM, P. Taylor Goetz wrote: > Votes cast by PPMC members are considered binding, but voting is open to > anyone.

Re: [VOTE] Storm Logo Contest - Round 1

#10 - 2 points #6 - 3 points On Mon, May 19, 2014 at 7:51 AM, Yudi Rahono wrote: > #10 - 5 Points > > > On Mon, May 19, 2014 at 9:25 AM, Sean Zhong wrote: > >> #3 - 3 points >> #10 - 2 points >> >> >> On Mon, May 19, 2014 at 2:55 AM, Cody A. Ray wrote: >> >>> #1 - 2 points >>> #4 - 1 point >>>