hm. Yeah, your port is good...have you seen this thread: http://stackoverflow.com/questions/27288380/fail-to-use-spark-cassandra-connector ? It seems that you might be running into version mis-match issues?
What versions of Spark/Cassandra-connector are you trying to use? On Tue, Jun 9, 2015 at 10:18 AM, Yasemin Kaya <godo...@gmail.com> wrote: > 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ç >
