spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Akhil Das <ak...@sigmoidanalytics.com>
Subject Re: Issue writing to Cassandra from Spark
Date Sun, 11 Jan 2015 06:15:19 GMT
Just make sure you are not connecting to the Old RPC Port (9160), new
binary port is running on 9042.

What is your rpc_address listed in cassandra.yaml? Also make sure you
have start_native_transport: *true *in the yaml file.

Thanks
Best Regards

On Sat, Jan 10, 2015 at 8:44 AM, Ankur Srivastava <
ankur.srivastava@gmail.com> wrote:

> Hi,
>
> We are currently using spark to join data in Cassandra and then write the
> results back into Cassandra. While reads happen with out any error during
> the writes we see many exceptions like below. Our environment details are:
>
> - Spark v 1.1.0
> - spark-cassandra-connector-java_2.10 v 1.1.0
>
> We are using below settings for the writer
>
> spark.cassandra.output.batch.size.rows=1
>
> spark.cassandra.output.concurrent.writes=1
>
> com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s)
> tried for query failed (tried: [] - use getErrors() for details)
>
> at
> com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:108)
>
> at com.datastax.driver.core.RequestHandler$1.run(RequestHandler.java:179)
>
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>
> at java.lang.Thread.run(Thread.java:745)
>
> Thanks
>
> Ankur
>

Mime
View raw message