Re: Remote RPC client disassociated

2016-07-01 Thread Akhil Das
ent:* 01 July 2016 11:38 > *To:* Joaquin Alzola > *Cc:* user@spark.apache.org > *Subject:* Re: Remote RPC client disassociated > > > > This looks like a version conflict, which version of spark are you using? > The Cassandra connector you are using is for Scala 2.10x and Spark 1

RE: Remote RPC client disassociated

2016-07-01 Thread Joaquin Alzola
HI Akhil I am using: Cassandra: 3.0.5 Spark: 1.6.1 Scala 2.10 Spark-cassandra connector: 1.6.0 From: Akhil Das [mailto:ak...@hacked.work] Sent: 01 July 2016 11:38 To: Joaquin Alzola Cc: user@spark.apache.org Subject: Re: Remote RPC client disassociated This looks like a version conflict, which

Re: Remote RPC client disassociated

2016-07-01 Thread Akhil Das
This looks like a version conflict, which version of spark are you using? The Cassandra connector you are using is for Scala 2.10x and Spark 1.6 version. On Thu, Jun 30, 2016 at 6:34 PM, Joaquin Alzola wrote: > HI List, > > > > I am launching this spark-submit job: > > > > hadoop@testbedocg:/mnt

RE: Remote RPC client disassociated

2016-06-30 Thread Joaquin Alzola
>>> 16/06/30 10:44:34 ERROR util.Utils: Uncaught exception in thread stdout >>> writer for python java.lang.AbstractMethodError: pyspark_cassandra.DeferringRowReader.read(Lcom/datastax/driver/core/Row;Lcom/datastax/spark/connector/CassandraRowMetadata;)Ljava/lang/Object; >> You are trying to call

Re: Remote RPC client disassociated

2016-06-30 Thread Jeff Zhang
>>> 16/06/30 10:44:34 ERROR util.Utils: Uncaught exception in thread stdout writer for python java.lang.AbstractMethodError: pyspark_cassandra.DeferringRowReader.read(Lcom/datastax/driver/core/Row;Lcom/datastax/spark/connector/CassandraRowMetadata;)Ljava/lang/Object; You are trying to call an ab