storm version delete

2015-11-24 Thread researcher cs
i'm new to Ubuntu and storm i want to delete the version of storm i have because i deleted the folder of storm from the directory only !! and i knew after that ,, it's wrong way .. how can i completely delete all versions of storm i've ?

Re: Trident Drpc - Scaling

2015-11-24 Thread Mohan Pandiyan
Can anybody help me with this? Regards, Mohan > On Nov 23, 2015, at 4:44 PM, Mohan Pandiyan wrote: > > I also see that not all the ackers in the topology are receiving acks from > bolts (out of 8 only 4 is receiving acks). > > >> On Nov 20, 2015, at 5:47 PM, Mohan Pandiyan wrote: >> >> We

Re: Kafka spout showing error in storm

2015-11-24 Thread Hugo Da Cruz Louro
Does this error occur right away, or only after running for a while? You can use a monitoring tool like JConsole [1] or JVisualVM to connect to the process and take a look to the JVM Heap Space plot. [1] - If the process is running locally for JConsole you will have to pass the JVM property -Dc

Re: Kafka spout showing error in storm

2015-11-24 Thread prakash a
This is the current configuration values. *drpc.childopts * -Xmx768m *storm.zookeeper.connection.timeout* 15000 *nimbus.childopts * -Xmx1024m -Djava.security.auth.login.config=/etc/storm/conf/storm_jaas.conf -javaagent:/usr/lib/storm/contrib/storm-jmxetric/lib/jmxetric-1.0.4.jar=host=localhost,p

Re: Kafka spout showing error in storm

2015-11-24 Thread Paul Poulosky
You might want to see if tuples are backing up and eating up memory, or if one of your components in the worker is holding on to stale references, and preventing them from being reaped. You can add the -XX:HeapDumpPath=/path/to/heapdumps -XX:HeapDumpOnOutOfMemoryError arguments to your worker ch

Re: Kafka spout showing error in storm

2015-11-24 Thread prakash a
> > We are getting below error from kafka spout on our storm cluster.Please > let us know which configuration need to be updated. > > > -- > > java.lang.OutOfMemoryError: Java heap space

Re: Kafka spout showing error in storm

2015-11-24 Thread Fan Jiang
Look at "worker.childopts" and "worker.heap.size.mb" in storm.yaml on the nimbus node. Try increasing worker's heap size by specifying JVM opt "-Xmx ". 2015-11-24 10:59 GMT-05:00 prakash a : > We are getting below error from kafka spout on our storm cluster.Please >> let us know which configurati

class objects vs single fields

2015-11-24 Thread Navdeep Agrawal
Hi , We have trident topologies where we have lot of fields in each log row(tuple) , would it be better to segregate fields and pass it other bolts/functions or create a class for those fields pass object of that class all along . we tried both the options and both of them works ,but due to l