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 <[email protected]> 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 >
