Hm, jars look ok, although it's a bit of a mess -- you have spark-assembly 1.3.0 but then core and streaming 1.3.1...It's generally a bad idea to mix versions. Spark-assembly bundless all spark packages, so either do them separately or use spark-assembly but don't mix like you've shown.
As to the port issue -- what about this: $bin/cassandra-cli -h localhost -p 9160 Connected to: "Test Cluster" on localhost/9160 Welcome to Cassandra CLI version 2.1.5 On Tue, Jun 9, 2015 at 1:29 PM, Yasemin Kaya <godo...@gmail.com> wrote: > My jar files are: > > cassandra-driver-core-2.1.5.jar > cassandra-thrift-2.1.3.jar > guava-18.jar > jsr166e-1.1.0.jar > spark-assembly-1.3.0.jar > spark-cassandra-connector_2.10-1.3.0-M1.jar > spark-cassandra-connector-java_2.10-1.3.0-M1.jar > spark-core_2.10-1.3.1.jar > spark-streaming_2.10-1.3.1.jar > > And my code from datastax spark-cassandra-connector > <https://github.com/datastax/spark-cassandra-connector/blob/master/spark-cassandra-connector-demos/simple-demos/src/main/java/com/datastax/spark/connector/demo/JavaApiDemo.java> > . > > Thanx alot. > yasemin > > 2015-06-09 18:58 GMT+03:00 Yana Kadiyska <yana.kadiy...@gmail.com>: > >> 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ç >>> >> >> > > > -- > hiç ender hiç >
