Hi Kay, It seems like your daemon connectivity is lacking, or perhaps the port is not opened for zookeeper connectivity. Ensure that all the worker and supervisor are up with access on the specific port.
you can Telnet from the machines to check the connectivity! On Mon, Mar 2, 2015 at 7:52 PM, kay <[email protected]> wrote: > Hello storm users, > > I would like to run a sample kafka-storm-cassandra chain. > > Kafka topic should contain simple numbers (10-50 items per second), > Storm should read this data and put it into the Cassandra cluster. > > I've already configured Kafka, Storm and Cassandra clusters. They work > well. Storm word-count example works well too (I was able to build > example with maven). > > The rest examples just failed: > https://github.com/Parsely/streamparse example failed with the > following message: > http://pastebin.com/7eMn38BK > > https://github.com/hmsonline/storm-cassandra example failed on TESTS: > http://pastebin.com/vCUyKREJ > If I skip tests and try to upload jar into the storm cluster - it can > not find the main class: > storm jar storm-cassandra-0.4.0-rc5-SNAPSHOT.jar > com.hmsonline.storm.cassandra.example.CassandraReachTopology > production-topology remote > http://pastebin.com/9uTCYSy8 > > Could someone provide me with the sample kafka-storm-cassandra > implementation (just read data from kafka and put it into cassandra > table)? It would be great if it will be based on python code. I use > Ubuntu 14.04, OpenJDK 7 for kafka, storm and CLI tests run environment > (I hope it is not a problem). Cassandra runs under the Oracle Java 7. > > Thanks in advance. >
