Re:batch processing in storm

2016-09-18 Thread darion.yaphet
Storm is a stream process system and use to process message one by one . I'm not very sure understood which you mean . Do you want to process a mini batch such as spark streaming ? At 2016-09-15 02:06:41, "Shushant Arora" wrote: Hi Is storm a right fit for batch

Re:Re: [Storm v0.9.6] DRPC Server periodically crashes after sometime

2016-08-13 Thread darion.yaphet
utions. But I am not sure, whats causing DRPC to consume soo much of memory. Any suggestions of how to debug this ? Thanks, ./Rahul On Wed, Aug 10, 2016 at 6:24 PM, darion.yaphet <fly...@163.com> wrote: Maybe you should check the JVM memory parameter -Xms and -Xmx to found memory usage.

Re:[Storm v0.9.6] DRPC Server periodically crashes after sometime

2016-08-10 Thread darion.yaphet
Maybe you should check the JVM memory parameter -Xms and -Xmx to found memory usage. At 2016-08-11 08:00:54, "Rahul R" wrote: I have a drpc server running in nimbus server. After every 'X' minutes, I see the following in the drpc log === java.lang.OutOfMemoryError:

Re:Storm HdfsSpout problem

2016-08-10 Thread darion.yaphet
Hi Jeyhun I'm not very sure what trouble you have . But I have fixed a bug about HDFSSpout [Expose TextFileReader public:STORM-1882] You can found at here : https://issues.apache.org/jira/browse/STORM-1882 在 2016-08-10 01:09:08,"Jeyhun Karimov" 写道: Hi community, I am

Re:Available Metrices

2016-07-18 Thread darion.yaphet
Hi : I'm not very sure what is available network and application metrics ? Is all kind of metics ? 在 2016-07-18 12:01:45,"Walid Aljoby" 写道: Hi Everyone, Anyone can please list the available network and application metrics in storm? It is good if there is specific

Re:Storm Benchmarks

2016-07-18 Thread darion.yaphet
It seems not found backtype.storm.generated.AlreadyAliveException .Because AlreadyAliveException have move to org.apache.storm.generated At 2016-07-18 18:06:36, "Walid Aljoby" wrote: >Hi Everyone, >Anyone used to run Storm Benchmarks in this site: 

Re:Where kafka spout stores offset

2016-06-28 Thread darion.yaphet
Hi : ZkHosts in SpoutConfig is use to set Kafka's ZooKeeper cluster host . Kafka Offset will store in ZooKeeper cluster which appoint out by Config.STORM_ZOOKEEPER_SERVERS . At 2016-06-28 23:57:38, "Igor Kuzmenko" wrote: I'm using Storm v 0.10.0. Offset obviously

Daemon Metrics/Monitoring Not Found

2016-06-27 Thread darion.yaphet
Hi team : I found Document Daemon Metrics/Monitoring (http://storm.apache.org/releases/1.0.1/storm-metrics-profiling-internal-actions.html) is miss .