failed to run storm

i've try to start storm nimbus and i got this message Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit. Unrecognized option: -client how can i got this error message? pls help. this is the java version java -version java version

Storm ordering of message

Hello Can we maintain ordering of message across multiple storm bolts . I want to make sure that when we receive eof .it will send to the csv writing bolt in order when all the message sent before processed and written into file. Will it be possible to have order of message with trident or storm

FW: Storm-Kafka support for 0.9 consumer

Hi, Per Michael Noll's article: http://www.michael-noll.com/blog/2014/05/27/kafka-storm-integration-example-tutorial/ "The Kafka project is working on an improved, consolidated consumer API for Kafka 0.9. Take a look at the respective discussions in the

Re: storm cassandra integration

Hi Crina, You can fork the external storm-cassandra from master branch. This module should be compatible from storm version 0.9.5 to 0.11. The actual fluent API is not stable and will be deprecated so you should directly use this following class :

Trident batch api

Hi , In trident is there any api for handling whole batch of tuples(list). similar to basefunction except I get batch of tridenttuple instead of single tuple . Thanks, Navdeep

storm cassandra integration

Hello, I was planning to integrate Cassandra with a storm project I am working on. I am using the latest version of storm (stable 0.10). But then, I researched and the component storm-cassandra from external composites of storm is available only starting the master branch of github so not with

Re: storm cassandra integration

Crina - I haven't used the Cassandra bolt, but in the past I have been able to import the current version of connectors like that into my project and use them directly. In other words, if you copy the external/storm-cassandra directory into your project you will likely be able to compile it

Re: storm cassandra integration

Hello, Thank you both for your answers. I was wondering if you know in around how many time this future release will be available, as I would like to integrate it when it will be stable. Crina 2015-12-08 14:56 GMT+01:00 Florian Hussonnois : > Hi Crina, > > You can fork

Re: FW: Storm-Kafka support for 0.9 consumer

Mark,            Here is the JIRA https://issues.apache.org/jira/browse/STORM-650 to make the kafak connector to use 0.9 . Its in the works. Thanks, Harsha On Tue, Dec 8, 2015, at 03:25 AM, Davis, Mark (TS R Galway) wrote: > Hi, > > Per Michael Noll’s article:

Re: Storm Scheduler

Thank you, already looked at it. But I found the answer from somewhere else. It is called periodically indeed and the default value is 10 seconds @storm.yaml *nimbus.monitor.freq.secs: 10* On Tue, Dec 8, 2015 at 7:50 PM, Matthias J. Sax wrote: > Hi Rudraneel, > > find an

RE: FW: Storm-Kafka support for 0.9 consumer

Thanks Harsha, missed that one! From: Harsha [mailto:st...@harsha.io] Sent: 08 December 2015 17:21 To: user@storm.apache.org Subject: Re: FW: Storm-Kafka support for 0.9 consumer Mark, Here is the JIRA https://issues.apache.org/jira/browse/STORM-650 to make the kafak connector to

Storm Scheduler

Hello , I am trying to develop a custom storm scheduler for some specific needs. I wanted to know if one can control the calling of the scheduler ( or, if it is called periodically , how to control the frequency ) -- Rudraneel Chakraborty

Thread[main,5,main] died

i'm new to storm , i faced problem in worker log file NIOServerCnxn [ERROR] Thread Thread[main,5,main] died clojure.lang.ArityException: Wrong number of args (3) passed to: worker$-main at clojure.lang.AFn.throwArity(AFn.java:437) at clojure.lang.AFn.invoke(AFn.java:47) at