Re: [VOTE] Storm Logo Contest - Round 1

[Roberto Coluccio]

#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
>>> #10 - 2 points
>>>
>>>
>>> On Sun, May 18, 2014 at 1:19 PM, Nathan Marz wrote:
>>>
 #10 - 5 points


 On Sun, May 18, 2014 at 4:47 AM, Marco  wrote:

> #3 - 2 pt.
> #4 - 1 pt.
> #5 - 2 pts.
>
>   Il Venerdì 16 Maggio 2014 18:41, P. Taylor Goetz 
> ha scritto:
>
>
> 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 voting. In the first
> round the top 3 entries will be selected to move onto the second round
> where the winner will be selected.
>
> The entries can be viewed on the storm website here:
>
> http://storm.incubator.apache.org/blog.html
>
> VOTING
>
> Each person can cast a single vote. A vote consists of 5 points that
> can be divided among multiple entries. To vote, list the entry number,
> followed by the number of points assigned. For example:
>
> #1 - 2 pts.
> #2 - 1 pt.
> #3 - 2 pts.
>
> Votes cast by PPMC members are considered binding, but voting is open
> to anyone.
>
> This vote will be open until Thursday, May 22 11:59 PM UTC.
>
> - Taylor
>
>


 --
 Twitter: @nathanmarz
 http://nathanmarz.com

>>>
>>>
>>>
>>> --
>>> Cody A. Ray, LEED AP
>>> cody.a@gmail.com
>>> 215.501.7891
>>>
>>
>>
>

Re: [VOTE] Storm Logo Contest - Round 1

[Viral Bajaria]

#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

[Laurent Thoulon]

#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 logos from the 11 entries 
received. This is the first of two rounds of voting. In the first round the top 
3 entries will be selected to move onto the second round where the winner will 
be selected. 

The entries can be viewed on the storm website here: 

http://storm.incubator.apache.org/blog.html 

VOTING 

Each person can cast a single vote. A vote consists of 5 points that can be 
divided among multiple entries. To vote, list the entry number, followed by the 
number of points assigned. For example: 

#1 - 2 pts. 
#2 - 1 pt. 
#3 - 2 pts. 

Votes cast by PPMC members are considered binding, but voting is open to 
anyone. 

This vote will be open until Thursday, May 22 11:59 PM UTC. 

- Taylor 

Understanding ACKing mechanism

[P Ghosh]

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("impactBolt", impactBolt, 5).fieldsGrouping("citySpout",
"citySpout_stream", new Fields("id"));

builder.setBolt("restaurantBolt", restaurantBolt,
5).fieldsGrouping("impactBolt", "impactBolt_stream", new Fields("id"));

builder.setBolt("theatresBolt", theatresBolt,
5).fieldsGrouping("impactBolt", "impactBolt_stream", new Fields("id"));

builder.setBolt("libraryBolt", libraryBolt, 5).fieldsGrouping("impactBolt",
"impactBolt_stream", new Fields("id"));

builder.setBolt("transportBolt", transportBolt,
5).fieldsGrouping("impactBolt", "impactBolt_stream", new Fields("id"));

builder.setBolt("crimeBolt", crimeBolt, 5).fieldsGrouping("impactBolt", "
impactBolt_stream", new Fields("id"));

builder.setBolt("combinerBolt", combinerBolt, 5)

 .fieldsGrouping("restaurantBolt", "restaurantBolt_stream", new
Fields("id"))

.fieldsGrouping("theatresBolt", "theatresBolt_stream", new
Fields("id"))

.fieldsGrouping("libraryBolt", "libraryBolt_stream", new
Fields("id"))

.fieldsGrouping("transportBolt", "transportBolt_stream", new
Fields("id"))

.fieldsGrouping("crimeBolt", "crimeBolt_stream", new Fields("id"));


*CombinerBolt*

*== *

public class CombinerBolt extends BaseRichBolt {

...

...

public void execute(Tuple input) {

String id = getId(tuple); //Gets the value corresponding to "id" from tuple

List idList = Arrays.asList(new Object[] { id });

GlobalStreamId streamId = new GlobalStreamId(tuple.getSourceComponent(),
tuple.getSourceStreamId());

Map parts;

if (!pendingTuples.containsKey(idList)) {

parts = new HashMap();

pendingTuples.put(idList, parts);

} else {

parts = pendingTuples.get(idList);

logger.debug("Pending Tuples [Count:" + pendingTuples.size() + "]");

if (parts.containsKey(streamId)) {

logger.warn("Received same side of single join twice, overriding");

}

parts.put(streamId, tuple);

if (parts.size() == _numSources) { //_numSources is computed at prepare(..)
using  context.getThisSources().size();

pendingTuples.remove(idList);

List tuples = new ArrayList(parts.values());

try {

processTuple(tuples); //This is where the actual document merging is done

} catch (Exception exc) {

logger.error("There was an exception processing Tuples [" + tuples + "]",
exc);

}

}

}

getOutputCollector().ack(tuple);

}

...

...

}

In my citySpout I have a work-In-Progress (WIP) set (in redis) [having a
"set" ensures that we don't have multiple transactions for the same city at
the same time], where every id (city) that is emitted is put in , and it is
removed when corresponding ack or failed is invoked on spout.

*1. *I'm seeing a lot of "Received same side of single join twice,
overriding"... my expectation, was otherwise, as I'm acking without waiting
for join...so there shouldn't be a lot of retry happening

*2. *I deactivated the topology and could see the WIP going down to "0" in
few seconds, however I continued to see my bolts working even when the WIP
has nothing , for another few seconds. items from WIP are removed only
when an ACK/FAIL is received at Spout. Based on the details provided in
https://github.com/nathanmarz/storm/wiki/Acking-framework-implementation  ,
my expectation was processing will stop the moment WIP is 0.

I'm curious, why my bolts are getting data.

I will continue to do more investigation. In the meant time  , if you see
any glaring issue with this approach pls. let me know.

Thanks,
Prasun

Test timed out (5000ms)

[Sergey Pichkurov]

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(), I am getting error:


java.lang.AssertionError: Test timed out (5000ms)

at
backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)

at clojure.lang.RestFn.invoke(RestFn.java:826)

at
backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)

at backtype.storm.Testing.completeTopology(Unknown Source)



This error not always arise, sometime test pass successfully.



Where I can change this timeout parameter? Or how can I disable this timeout?

Does Esper work with Storm 0.9.x version

[Nishu]

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 it works with 0.9.x version.

How to catch exceptions from a Spout

[Alexis Sukrieh]

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 topology with a Spout that emits tweets from the "Sample"
streaming API, using twitter4j.

This is working fine, but every once in a while, I get an exception from
twitter4j which results in an "unserializable exception" error showing up
in my Storm UI (under the "last error" field).

I'd like to catch that exception but I clearly have no clue where this can
be caught. Anyone has an idea on the good way (if any) to catch exceptions
in a Spout?

Also, my Spout's stats remain empty (0 acked and 0 failed) no matter of my
bolts activities (counters are updated perfectly for them). Is there any
reason for that? I thought the stats for the Spout would be the sum of the
bolts.

Should I ack/fail tuples from the Spout itself? If so, it looks a bit
complicated to implement, it would mean to keep a state somewhere between
bolts and spout. Am I missing something?

Thanks a lot for your help!

-- 
Alexis Sukrieh

http://twitter.com/sukria - http://blog.sukria.net

"People get annoyed when you try to debug them." -- Larry Wall

Storm with video/audio streams

[Suparno Datta]

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 something
like detecting and tracking faces from a live video stream using Storm. But
i am not sure if this is even feasible. Most of the examples i see deal
with text streams. Has any one here already tried/ thought of something
like this ?

Thanks,

-- 
Suparno Datta

Re: [VOTE] Storm Logo Contest - Round 1

[Bryan Stone]

#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 selecting the top 3 Storm logos from the 11
>entries received. This is the first of two rounds of voting. In the first
>round the top 3 entries will be selected to move onto the second round
>where the winner will be selected.
>
>The entries can be viewed on the storm website here:
>
>http://storm.incubator.apache.org/blog.html
>
>VOTING
>
>Each person can cast a single vote. A vote consists of 5 points that can
>be divided among multiple entries. To vote, list the entry number,
>followed by the number of points assigned. For example:
>
>#1 - 2 pts.
>#2 - 1 pt.
>#3 - 2 pts.
>
>Votes cast by PPMC members are considered binding, but voting is open to
>anyone.
>
>This vote will be open until Thursday, May 22 11:59 PM UTC.
>
>- Taylor



==

This e-mail, including any attachments, is intended for the exclusive use of 
the person(s) to which it is addressed and may contain proprietary, 
confidential and/or privileged information. If the reader of this e-mail is not 
the intended recipient or his or her authorized agent, any review, use, 
printing, copying, disclosure, dissemination or distribution of this e-mail is 
strictly prohibited. If you think that you have received the e-mail in error, 
please notify the sender immediately by return e-mail, delete this 
communication and destroy all copies.

==

Re: [VOTE] Storm Logo Contest - Round 1

[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 top 3 Storm logos from the 11 entries 
received. This is the first of two rounds of voting. In the first round the top 
3 entries will be selected to move onto the second round where the winner will 
be selected.

The entries can be viewed on the storm website here:

http://storm.incubator.apache.org/blog.html

VOTING

Each person can cast a single vote. A vote consists of 5 points that can be 
divided among multiple entries. To vote, list the entry number, followed by the 
number of points assigned. For example:

#1 - 2 pts.
#2 - 1 pt.
#3 - 2 pts.

Votes cast by PPMC members are considered binding, but voting is open to anyone.

This vote will be open until Thursday, May 22 11:59 PM UTC.

- Taylor

Re: [VOTE] Storm Logo Contest - Round 1

[Bilal Al Fartakh]

#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 top 3 Storm logos from the 11
>> entries received. This is the first of two rounds of voting. In the first
>> round the top 3 entries will be selected to move onto the second round
>> where the winner will be selected.
>>
>> The entries can be viewed on the storm website here:
>>
>> http://storm.incubator.apache.org/blog.html
>>
>> VOTING
>>
>> Each person can cast a single vote. A vote consists of 5 points that can
>> be divided among multiple entries. To vote, list the entry number, followed
>> by the number of points assigned. For example:
>>
>> #1 - 2 pts.
>> #2 - 1 pt.
>> #3 - 2 pts.
>>
>> Votes cast by PPMC members are considered binding, but voting is open to
>> anyone.
>>
>> This vote will be open until Thursday, May 22 11:59 PM UTC.
>>
>> - Taylor
>>
>>


-- 
*Al Fartakh Bilal*

Re: Test timed out (5000ms)

[Derek Dagit]

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 needs to be longer we could increase it.

If you continue to see the time-out, it could be that the test really is 
hanging somehow.

--
Derek

On 5/19/14, 4:57, Sergey Pichkurov wrote:

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(), I am getting error:


java.lang.AssertionError: Test timed out (5000ms)

 at
backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)

 at clojure.lang.RestFn.invoke(RestFn.java:826)

 at
backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)

 at backtype.storm.Testing.completeTopology(Unknown Source)



This error not always arise, sometime test pass successfully.



Where I can change this timeout parameter? Or how can I disable this timeout?

Notify workers when a worker crashes

[Florian Duros]

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: Storm with video/audio streams

[Michael Rose]

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 
mich...@fullcontact.com


On Mon, May 19, 2014 at 6:13 AM, Suparno Datta wrote:

> 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 something
> like detecting and tracking faces from a live video stream using Storm. But
> i am not sure if this is even feasible. Most of the examples i see deal
> with text streams. Has any one here already tried/ thought of something
> like this ?
>
> Thanks,
>
> --
> Suparno Datta
>

Re: Externalize storm.yaml file

[P Ghosh]

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 file would be placed and
> Storm cluster should access that file.
>
>
>
> Is it possible to configure config file location in Storm. By default it
> refers to $STORM_DIR/conf/strom.yaml
>
> Can we configure conf directory in Storm to point it to a different
> location so as jobs to know where to pick the config file from.
>
>
>
> Thanks in advance
>
>
>
> Regards,
>
> Neha
>
> DISCLAIMER == This e-mail may contain privileged and confidential
> information which is the property of Persistent Systems Ltd. It is intended
> only for the use of the individual or entity to which it is addressed. If
> you are not the intended recipient, you are not authorized to read, retain,
> copy, print, distribute or use this message. If you have received this
> communication in error, please notify the sender and delete all copies of
> this message. Persistent Systems Ltd. does not accept any liability for
> virus infected mails.
>

Re: Test timed out (5000ms)

[Sergey Pichkurov]

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
>
> 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 needs to be longer we could increase it.
>
> If you continue to see the time-out, it could be that the test really is
> hanging somehow.
>
> --
> Derek
>
>
> On 5/19/14, 4:57, Sergey Pichkurov wrote:
>
>> 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(), I am getting error:
>>
>>
>> java.lang.AssertionError: Test timed out (5000ms)
>>
>>  at
>> backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)
>>
>>  at clojure.lang.RestFn.invoke(RestFn.java:826)
>>
>>  at
>> backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)
>>
>>  at backtype.storm.Testing.completeTopology(Unknown
>> Source)
>>
>>
>>
>> This error not always arise, sometime test pass successfully.
>>
>>
>>
>> Where I can change this timeout parameter? Or how can I disable this
>> timeout?
>>
>>

Re: Test timed out (5000ms)

[Derek Dagit]

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*



On Mon, May 19, 2014 at 5:18 PM, Derek Dagit  wrote:





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 needs to be longer we could increase it.

If you continue to see the time-out, it could be that the test really is
hanging somehow.

--
Derek


On 5/19/14, 4:57, Sergey Pichkurov wrote:


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(), I am getting error:


java.lang.AssertionError: Test timed out (5000ms)

  at
backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)

  at clojure.lang.RestFn.invoke(RestFn.java:826)

  at
backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)

  at backtype.storm.Testing.completeTopology(Unknown
Source)



This error not always arise, sometime test pass successfully.



Where I can change this timeout parameter? Or how can I disable this
timeout?

Re: Test timed out (5000ms)

[Sergey Pichkurov]

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.
>
> --
> 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*
>>
>>
>>
>>
>> On Mon, May 19, 2014 at 5:18 PM, Derek Dagit 
>> wrote:
>>
>>
>
>>> 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 needs to be longer we could increase it.
>>>
>>> If you continue to see the time-out, it could be that the test really is
>>> hanging somehow.
>>>
>>> --
>>> Derek
>>>
>>>
>>> On 5/19/14, 4:57, Sergey Pichkurov wrote:
>>>
>>>  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(), I am getting error:


 java.lang.AssertionError: Test timed out (5000ms)

   at
 backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)

   at clojure.lang.RestFn.invoke(RestFn.java:826)

   at
 backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)

   at backtype.storm.Testing.completeTopology(Unknown
 Source)



 This error not always arise, sometime test pass successfully.



 Where I can change this timeout parameter? Or how can I disable this
 timeout?



>>

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

[Raja Cherukuri]

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 called, it would release the library
from path.
d) Then update the OS's newer version of the native library and
e) then rebalance back to the old bolt count.

Will this work ?

Re: Performance metrics in storm

[padma priya chitturi]

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/06/sending-metrics-from-storm-to-graphite/
>
> Best,
> Michael
>
>
>
> On 01/30/2014 01:23 PM, padma priya chitturi wrote:
> > Hi All,
> >
> > I wanted to justify the performance of storm by considering various
> > metrics/counters. What could be various tools that can give graphical
> > representation of the metrics like response time, messages processes
> > /sec etc. How can we collect the metrics ?
> >
> >
> >
> > Thanks,
> > Padma Ch.
>
>

Re: [VOTE] Storm Logo Contest - Round 1

[abhishek.priya]

#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 on selecting the top 3 Storm logos from the 11 entries 
received. This is the first of two rounds of voting. In the first round the top 
3 entries will be selected to move onto the second round where the winner will 
be selected.

The entries can be viewed on the storm website here:

http://storm.incubator.apache.org/blog.html

VOTING

Each person can cast a single vote. A vote consists of 5 points that can be 
divided among multiple entries. To vote, list the entry number, followed by the 
number of points assigned. For example:

#1 - 2 pts.
#2 - 1 pt.
#3 - 2 pts.

Votes cast by PPMC members are considered binding, but voting is open to anyone.

This vote will be open until Thursday, May 22 11:59 PM UTC.

- Taylor




#9 - 2 Points


#1 - 3 Points


-- 



- Uditha Bandara Wijerathna -

Re: [VOTE] Storm Logo Contest - Round 1

[Binh Nguyen Van]

#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
>
> On Thu, May 15, 2014 at 9:58 PM, 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 voting. In the first
>> round the top 3 entries will be selected to move onto the second round
>> where the winner will be selected.
>>
>> The entries can be viewed on the storm website here:
>>
>> http://storm.incubator.apache.org/blog.html
>>
>> VOTING
>>
>> Each person can cast a single vote. A vote consists of 5 points that can
>> be divided among multiple entries. To vote, list the entry number, followed
>> by the number of points assigned. For example:
>>
>> #1 - 2 pts.
>> #2 - 1 pt.
>> #3 - 2 pts.
>>
>> Votes cast by PPMC members are considered binding, but voting is open to
>> anyone.
>>
>> This vote will be open until Thursday, May 22 11:59 PM UTC.
>>
>> - Taylor
>>
>
>
> #9 - 2 Points
> #1 - 3 Points
> --
> - Uditha Bandara Wijerathna -
>

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

[Tao, Jing]

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" 
mailto:j...@webmd.net>> wrote:

Hi,

I am using storm 0.9.0.1, kafka 0.8, and storm-kafka-0.8-plus.  In 
LocalCluster, after fetching and processing about 18,000 messages, the spout 
stops fetching from Kafka even though there are new messages in the queue.
There are no errors in the storm or kafka logs.  Any idea why this is happening?

Thanks,
Jing

Re: [VOTE] Storm Logo Contest - Round 1

[Neville Li]

#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‎, ‎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 on selecting the top 3 Storm logos from the 11
>>> entries received. This is the first of two rounds of voting. In the first
>>> round the top 3 entries will be selected to move onto the second round
>>> where the winner will be selected.
>>>
>>> The entries can be viewed on the storm website here:
>>>
>>> http://storm.incubator.apache.org/blog.html
>>>
>>> VOTING
>>>
>>> Each person can cast a single vote. A vote consists of 5 points that can
>>> be divided among multiple entries. To vote, list the entry number, followed
>>> by the number of points assigned. For example:
>>>
>>> #1 - 2 pts.
>>> #2 - 1 pt.
>>> #3 - 2 pts.
>>>
>>> Votes cast by PPMC members are considered binding, but voting is open to
>>> anyone.
>>>
>>> This vote will be open until Thursday, May 22 11:59 PM UTC.
>>>
>>> - Taylor
>>>
>>
>>
>> #9 - 2 Points
>> #1 - 3 Points
>> --
>> - Uditha Bandara Wijerathna -
>>
>
>