Is your cassandra installation actually listening on 9160? lsof -i :9160COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME java 29232 ykadiysk 69u IPv4 42152497 0t0 TCP localhost:9160 (LISTEN)
I am running an out-of-the box cassandra conf where rpc_address: localhost # port for Thrift to listen for clients on rpc_port: 9160 On Tue, Jun 9, 2015 at 7:36 AM, Yasemin Kaya <godo...@gmail.com> wrote: > 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ç >
