Yes my cassandra is listening on 9160 I think. Actually I know from yaml file. The file includes :
rpc_address: localhost # port for Thrift to listen for clients on rpc_port: 9160 I check the port "nc -z localhost 9160; echo $?" it returns me "0". I think it close, should I open this port ? 2015-06-09 16:55 GMT+03:00 Yana Kadiyska <yana.kadiy...@gmail.com>: > 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ç >> > > -- hiç ender hiç
