Re: IllegalArgumentException while saving RDD to cassandra using Spark Cassandra Connector

2018-07-22 Thread M Singh
Hi Folks: Just checking if anyone has any pointers for the cassandra spark connector issue I've mentioned : IllegalArgumentException on executing save after repartition by cassandra replica:val customersRdd = customers.rdd.repartitionByCassandraReplica("test","customers")  customersRdd.saveToC

IllegalArgumentException while saving RDD to cassandra using Spark Cassandra Connector

2018-07-18 Thread M Singh
Hi Cassandra/Spark experts: I am working with on a project to save Spark dataframe to cassandra and am getting an exception regarding row size not valid (see below). I tried to trace the code in the connector and it appears that the row size (3 below) is different from the column count (which tu