You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by steve tueno <st...@gmail.com> on 2015/10/08 18:17:49 UTC

Please help

Hi,
I'm implementing WordCount with storm. Sentences are read in a file and my
problem is what it the best way to stop LocalCluster when splout reach end
of file...

Cordialement,
TUENO FOTSO STEVE JEFFREY
Élève Ingénieur
5GI ENSP
+237 676 57 17 28
https://play.google.com/store/apps/details?id=com.polytech.remotecomputer
http://github.com/stuenofotso/remoteComputer
https://play.google.com/store/apps/details?id=com.polytech.androidsmssender
https://github.com/stuenofotso/notre-jargon

Re: Please help

Posted by steve tueno <st...@gmail.com>.

thanks you very much

Cordialement,
TUENO FOTSO STEVE JEFFREY
Élève Ingénieur
5GI ENSP
+237 676 57 17 28
https://play.google.com/store/apps/details?id=com.polytech.remotecomputer
http://github.com/stuenofotso/remoteComputer
https://play.google.com/store/apps/details?id=com.polytech.androidsmssender
https://github.com/stuenofotso/notre-jargon

2015-10-08 17:37 GMT+01:00 Ravi Sharma <pi...@gmail.com>:

> Hi Steve,
> Storm 's basic design is to process stream(open ended or say No End) in
> real time. There will be few hack ways of stoping the cluster once file is
> finished but i guess none of them will be good looking.
> Basically your storm cluster should be running all the time and waiting
> for more message to process.
>
> One dirty way is to send poison tuple after end of file, Bolt will receive
> it, acknowledge it, and then when you receive ack in Spout you can kill ur
> JVM manually. (Not good looking).
>
> Ravi.
>
> On Thu, Oct 8, 2015 at 5:17 PM, steve tueno <st...@gmail.com> wrote:
>
>> Hi,
>> I'm implementing WordCount with storm. Sentences are read in a file and
>> my problem is what it the best way to stop LocalCluster when splout reach
>> end of file...
>>
>> Cordialement,
>> TUENO FOTSO STEVE JEFFREY
>> Élève Ingénieur
>> 5GI ENSP
>> +237 676 57 17 28
>> https://play.google.com/store/apps/details?id=com.polytech.remotecomputer
>> http://github.com/stuenofotso/remoteComputer
>>
>> https://play.google.com/store/apps/details?id=com.polytech.androidsmssender
>>
>> https://github.com/stuenofotso/notre-jargon
>>
>
>

Re: Please help

Posted by Ravi Sharma <pi...@gmail.com>.

Hi Steve,
Storm 's basic design is to process stream(open ended or say No End) in
real time. There will be few hack ways of stoping the cluster once file is
finished but i guess none of them will be good looking.
Basically your storm cluster should be running all the time and waiting for
more message to process.

One dirty way is to send poison tuple after end of file, Bolt will receive
it, acknowledge it, and then when you receive ack in Spout you can kill ur
JVM manually. (Not good looking).

Ravi.

On Thu, Oct 8, 2015 at 5:17 PM, steve tueno <st...@gmail.com> wrote:

> Hi,
> I'm implementing WordCount with storm. Sentences are read in a file and my
> problem is what it the best way to stop LocalCluster when splout reach end
> of file...
>
> Cordialement,
> TUENO FOTSO STEVE JEFFREY
> Élève Ingénieur
> 5GI ENSP
> +237 676 57 17 28
> https://play.google.com/store/apps/details?id=com.polytech.remotecomputer
> http://github.com/stuenofotso/remoteComputer
> https://play.google.com/store/apps/details?id=com.polytech.androidsmssender
>
> https://github.com/stuenofotso/notre-jargon
>