Thanks alot Mohammed, Gerard and Yana. I can write to table, but exception returns me. It says "*Exception in thread "main" java.io.IOException: Failed to open thrift connection to Cassandra at 127.0.0.1:9160 <http://127.0.0.1:9160>*"
In yaml file : rpc_address: localhost rpc_port: 9160 And at project : .set("spark.cassandra.connection.host", "127.0.0.1") .set("spark.cassandra.connection.rpc.port", "9160"); or .set("spark.cassandra.connection.host", "localhost") .set("spark.cassandra.connection.rpc.port", "9160"); whatever I write setting, I get same exception. Any help ?? 2015-06-08 18:23 GMT+03:00 Yana Kadiyska <yana.kadiy...@gmail.com>: > yes, whatever you put for listen_address in cassandra.yaml. Also, you > should try to connect to your cassandra cluster via bin/cqlsh to make sure > you have connectivity before you try to make a a connection via spark. > > On Mon, Jun 8, 2015 at 4:43 AM, Yasemin Kaya <godo...@gmail.com> wrote: > >> Hi, >> I run my project on local. How can find ip address of my cassandra host >> ? From cassandra.yaml or ?? >> >> yasemin >> >> 2015-06-08 11:27 GMT+03:00 Gerard Maas <gerard.m...@gmail.com>: >> >>> ????? = <ip address of your cassandra host> >>> >>> On Mon, Jun 8, 2015 at 10:12 AM, Yasemin Kaya <godo...@gmail.com> wrote: >>> >>>> Hi , >>>> >>>> How can I find spark.cassandra.connection.host? And what should I >>>> change ? Should I change cassandra.yaml ? >>>> >>>> Error says me *"Exception in thread "main" java.io.IOException: Failed >>>> to open native connection to Cassandra at {127.0.1.1}:9042"* >>>> >>>> What should I add *SparkConf sparkConf = new >>>> SparkConf().setAppName("JavaApiDemo").set(**"spark.driver.allowMultipleContexts", >>>> "true").set("spark.cassandra.connection.host", ?????);* >>>> >>>> Best >>>> yasemin >>>> >>>> 2015-06-06 3:04 GMT+03:00 Mohammed Guller <moham...@glassbeam.com>: >>>> >>>>> Check your spark.cassandra.connection.host setting. It should be >>>>> pointing to one of your Cassandra nodes. >>>>> >>>>> >>>>> >>>>> Mohammed >>>>> >>>>> >>>>> >>>>> *From:* Yasemin Kaya [mailto:godo...@gmail.com] >>>>> *Sent:* Friday, June 5, 2015 7:31 AM >>>>> *To:* user@spark.apache.org >>>>> *Subject:* Cassandra Submit >>>>> >>>>> >>>>> >>>>> Hi, >>>>> >>>>> >>>>> >>>>> I am using cassandraDB in my project. I had that error *Exception in >>>>> thread "main" java.io.IOException: Failed to open native connection to >>>>> Cassandra at {127.0.1.1}:9042* >>>>> >>>>> >>>>> >>>>> I think I have to modify the submit line. What should I add or remove >>>>> when I submit my project? >>>>> >>>>> >>>>> >>>>> Best, >>>>> >>>>> yasemin >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> >>>>> hiç ender hiç >>>>> >>>> >>>> >>>> >>>> -- >>>> hiç ender hiç >>>> >>> >>> >> >> >> -- >> hiç ender hiç >> > > -- hiç ender hiç