I couldn't find any solution. I can write but I can't read from Cassandra. 2015-06-09 8:52 GMT+03:00 Yasemin Kaya <godo...@gmail.com>:
> 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ç > -- hiç ender hiç
