Re: Error in submitting Topology

cd Storm cd storm mvn clean install bin/storm jar /home/user/storm/storm-starter.jar "storm.starter.WordCountTopology" On Dec 30, 2013 4:41 AM, "researcher cs" wrote: > Thanks > *Abhishek but i'm still until now have problem to find or load main class > when i wrote this command *user@ubuntu:~/St

Re: Error in submitting Topology

Don't forget to rename file m2-pom.xml to pom.xml and also post your directory "tree" structure. I want to check whether your source WordCountTopology.java exists or not. On Mon, Dec 30, 2013 at 10:52 AM, Aniket Alhat wrote: > cd Storm > cd storm > mvn clean install &g

Re: how to benchmark or evaluate a storm cluster performance?

Hello ch huang, I guess you can start with this https://github.com/stormprocessor/storm-benchmark On Mon, Jan 13, 2014 at 3:20 PM, ch huang wrote: > hi,maillist: > now i build a storm cluster successfully,what i want to do is test > the cluster performance and evaluate it's max calculate

Serialization of Bolt

Hello, I want to periodically serialize the state of a bolt and remember what tuples it has processed up until particular point. Then when you restart the Bolt you can deserialize that state into the new bolt instance and replay/*process* the tuples from where it was last. Consider the WordCount T

Re: Serialization of Bolt

to sync to some remote datebase. Off course this is > somehow slow, maybe batching could help. In another thread someone > discussed using Cassandra with some partition tricks... Cheers > Am 17.01.2014 11:32 schrieb "Aniket Alhat" : > >> Hello, >> I want to per

Storm-contrib Contribution

Hello , I would like to be an contributor to storm-contrib project. I have implemented a module *Stateful Bolts* ( https://issues.apache.org/jira/browse/STORM-45) quoted by Nathan long time back. It can also act as *storm-redis* prototype as per the other module in storm-contrib. I have designed

Re: How to efficiently store the intermediate result of a bolt, and so it can be replayed after the crashes?

I hope this helps https://github.com/pict2014/storm-redis On Feb 7, 2014 12:07 AM, "Cheng-Kang Hsieh (Andy)" wrote: > Sorry, I realized that question was badly written. Simply put, my question > is that is there a recommended way to store the tuples emitted by a BOLT so > that the tuples can be

Re: storm and storm-Kafka spout

Hi Saurabh, Sorry I could not identify the exact cause of this, in mean time you can checkout this thing *[kafka-storm-redis]* https://github.com/pict2014/storm-redis I hope this satisfies your requirement temporarily. On Mon, Feb 17, 2014 at 5:28 AM, Saurabh Agarwal (BLOOMBERG/ 731 LEXIN) < saga

Re: Integrating STORM with Redis

Hi Abhinav, I guess problem is on the worker node where your code gets deployed. Try installing redis on the machine on which you are deploying your code. In the mean time you can checkout this repo and compare it with your code. I recommend Maven. https://github.com/aniketalhat/StatefulBolts On

Re: Starting a new storm project from scratch

Before following the above procedure fire an eclipse:eclipse command. This will create the essential project structure required for eclipse. And after that don't forget to fire one more command eclipse:clean. On Feb 22, 2014 6:33 PM, "Chris James" wrote: > Hi all. I'll preface this with my apol

Re: Transactional Topology Question

Hello Abhishek, I can try to answer this question as per my knowledge. At first you need to understand that Transactional Topologies are been deprecated. Trident is something which is widely used now days. Now if you have gone through the wiki https://github.com/nathanmarz/storm/wiki/Transactional