Mohammed
*From:* Yasemin Kaya [mailto:godo...@gmail.com]
*Sent:* Tuesday, June 9, 2015 11:32 AM
*To:* Yana Kadiyska
*Cc:* Gerard Maas; Mohammed Guller; user@spark.apache.org
*Subject:* Re: Cassandra Submit
I removed core and streaming jar. And the exception still same.
I tried what
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
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 ?
Sorry my answer I hit terminal lsof -i:9160: result is
lsof -i:9160
COMMAND PIDUSER FD TYPE DEVICE SIZE/OFF NODE NAME
java7597 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
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
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
-cassandra-2.1.5$ bin/cassandra-cli -h 127.0.0.1 -p 9160
Mohammed
From: Yasemin Kaya [mailto:godo...@gmail.com]
Sent: Tuesday, June 9, 2015 11:32 AM
To: Yana Kadiyska
Cc: Gerard Maas; Mohammed Guller; user@spark.apache.org
Subject: Re: Cassandra Submit
I removed core and streaming jar
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
I removed core and streaming jar. And the exception still same.
I tried what you said then results:
~/cassandra/apache-cassandra-2.1.5$ bin/cassandra-cli -h localhost -p 9160
Connected to: Test Cluster on localhost/9160
Welcome to Cassandra CLI version 2.1.5
The CLI is deprecated and will be
jar has the wrong version of the library that
SCC is trying to use. Welcome to jar hell!
Mohammed
From: Yasemin Kaya [mailto:godo...@gmail.com]
Sent: Tuesday, June 9, 2015 12:24 PM
To: Mohammed Guller
Cc: Yana Kadiyska; Gerard Maas; user@spark.apache.org
Subject: Re: Cassandra Submit
My code
Is your cassandra installation actually listening on 9160?
lsof -i :9160COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME
java29232 ykadiysk 69u IPv4 42152497 0t0 TCP
localhost:9160 (LISTEN)
I am running an out-of-the box cassandra conf where
rpc_address: localhost
#
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
? = 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:
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
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
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
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
17 matches
Mail list logo
