You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Seth Ammons SG <se...@sendgrid.com> on 2015/12/21 20:26:14 UTC
Help getting storm-starter to work
Hey, I hope this is the right forum for this kind of question. I’m trying
to get the storm-starter
<https://github.com/apache/storm/tree/master/examples/storm-starter> to
work. When I run the following:
$ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology`
I get an error <https://gist.github.com/sethgrid/c64eb01deec37f5b95d1>:
Error on initialization of server mk-worker
java.lang.RuntimeException: java.lang.ClassNotFoundException:
backtype.storm.testing.TestWordSpout
I’m not a java developer, so I’m not sure exactly how imports are supposed
to work. I do see
/storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java.
I am running my commands from ./examples/storm-starter as per the
documentation linked above.
Any help would be great; I’d enjoy being able to get started :)
Thanks for any assistance!
—Seth
RE : Custom implementation of ISpoutWaitStrategy
Posted by Denis DEBARBIEUX <dd...@norsys.fr>.
Thanks.
Denis
________________________________________
De : P. Taylor Goetz [ptgoetz@gmail.com]
Date d'envoi : mardi 22 décembre 2015 19:13
À : user@storm.apache.org
Objet : Re: Custom implementation of ISpoutWaitStrategy
If the call to a spout's `nextTuple()` method does not emit anything, Storm will call the `emptyEmit()` method with the number of times `nextTuple()` has consecutively failed to emit anything (`streak` will be reset to 0 if the spout emits something).
-Taylor
> On Dec 22, 2015, at 6:03 AM, Denis DEBARBIEUX <dd...@norsys.fr> wrote:
>
> Dear all,
>
> I would to implement my own SpoutWaitStrategy. So I have to implement
> ISpoutWaitStrategy and then prepare and emptyEmit methods.
>
> But, I do not understand the meaning of the parameter 'streak'. How
> should I use it?
>
> Thanks for your help.
>
> Denis
>
> ---
> L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
> https://www.avast.com/antivirus
>
Re: Custom implementation of ISpoutWaitStrategy
Posted by "P. Taylor Goetz" <pt...@gmail.com>.
If the call to a spout's `nextTuple()` method does not emit anything, Storm will call the `emptyEmit()` method with the number of times `nextTuple()` has consecutively failed to emit anything (`streak` will be reset to 0 if the spout emits something).
-Taylor
> On Dec 22, 2015, at 6:03 AM, Denis DEBARBIEUX <dd...@norsys.fr> wrote:
>
> Dear all,
>
> I would to implement my own SpoutWaitStrategy. So I have to implement
> ISpoutWaitStrategy and then prepare and emptyEmit methods.
>
> But, I do not understand the meaning of the parameter 'streak'. How
> should I use it?
>
> Thanks for your help.
>
> Denis
>
> ---
> L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
> https://www.avast.com/antivirus
>
Custom implementation of ISpoutWaitStrategy
Posted by Denis DEBARBIEUX <dd...@norsys.fr>.
Dear all,
I would to implement my own SpoutWaitStrategy. So I have to implement
ISpoutWaitStrategy and then prepare and emptyEmit methods.
But, I do not understand the meaning of the parameter 'streak'. How
should I use it?
Thanks for your help.
Denis
---
L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
https://www.avast.com/antivirus
Re: Help getting storm-starter to work
Posted by Seth Ammons SG <se...@sendgrid.com>.
Hi Ankur,
Thanks for the follow up; I’ve been out with a stomach bug for a couple of
days.
Looking for jar files, I see two. Neither of them contain TestWordSpout.
I used find . -name "*.jar" -exec grep TestWordSpout {} \;. The two files
found:
./target/original-storm-starter-0.11.0-SNAPSHOT.jar
./target/storm-starter-0.11.0-SNAPSHOT.jar
On Mon, Dec 21, 2015 at 10:41 PM Ankur Garg <an...@gmail.com> wrote:
> hi ,
>
> In the jar can u see TestWordSpout.java ? .
>
> On Tue, Dec 22, 2015 at 12:56 AM, Seth Ammons SG <seth.ammons@sendgrid.com
> > wrote:
>
>> Hey, I hope this is the right forum for this kind of question. I’m trying
>> to get the storm-starter
>> <https://github.com/apache/storm/tree/master/examples/storm-starter> to
>> work. When I run the following:
>>
>> $ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology`
>>
>> I get an error <https://gist.github.com/sethgrid/c64eb01deec37f5b95d1>:
>>
>> Error on initialization of server mk-worker
>> java.lang.RuntimeException: java.lang.ClassNotFoundException: backtype.storm.testing.TestWordSpout
>>
>> I’m not a java developer, so I’m not sure exactly how imports are
>> supposed to work. I do see
>> /storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java.
>>
>> I am running my commands from ./examples/storm-starter as per the
>> documentation linked above.
>>
>> Any help would be great; I’d enjoy being able to get started :)
>> Thanks for any assistance!
>> —Seth
>>
>>
>
>
Re: Help getting storm-starter to work
Posted by Ankur Garg <an...@gmail.com>.
hi ,
In the jar can u see TestWordSpout.java ? .
On Tue, Dec 22, 2015 at 12:56 AM, Seth Ammons SG <se...@sendgrid.com>
wrote:
> Hey, I hope this is the right forum for this kind of question. I’m trying
> to get the storm-starter
> <https://github.com/apache/storm/tree/master/examples/storm-starter> to
> work. When I run the following:
>
> $ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology`
>
> I get an error <https://gist.github.com/sethgrid/c64eb01deec37f5b95d1>:
>
> Error on initialization of server mk-worker
> java.lang.RuntimeException: java.lang.ClassNotFoundException: backtype.storm.testing.TestWordSpout
>
> I’m not a java developer, so I’m not sure exactly how imports are supposed
> to work. I do see
> /storm-core/src/jvm/backtype/storm/testing/TestWordSpout.java.
>
> I am running my commands from ./examples/storm-starter as per the
> documentation linked above.
>
> Any help would be great; I’d enjoy being able to get started :)
> Thanks for any assistance!
> —Seth
>
>