Sorry my answer I hit terminal lsof -i:9160: result is lsof -i:9160 COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME java 7597 inosens 101u IPv4 85754 0t0 TCP localhost:9160 (LISTEN)
so 9160 port is available or not ? 2015-06-09 17:16 GMT+03:00 Yasemin Kaya <godo...@gmail.com>: > 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ç > -- hiç ender hiç
