Re: Spark Cassandra Connector issue

2015-08-11 Thread satish chandra j
it$.main(SparkSubmit.scala:75) >>> >>> at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) >>> >>> >>> Previously I could fix the issue by changing the order of arguments >>> passing in DSE command line interface but now I am not sure why t

Re: Spark Cassandra Connector issue

2015-08-10 Thread satish chandra j
-cassandra-connector-java_2.10.1.1.1.jar) >> >> >> Thanks for support >> >> >> Satish Chandra >> >> On Mon, Aug 10, 2015 at 6:19 PM, Dean Wampler >> wrote: >> >>> Add the other Cassandra dependencies (dse.jar, >>> spark-cassandra-con

Re: Spark Cassandra Connector issue

2015-08-10 Thread Dean Wampler
gt; >> Dean Wampler, Ph.D. >> Author: Programming Scala, 2nd Edition >> <http://shop.oreilly.com/product/0636920033073.do> (O'Reilly) >> Typesafe <http://typesafe.com> >> @deanwampler <http://twitter.com/deanwampler> >> http://polyglotprogr

Re: Spark Cassandra Connector issue

2015-08-10 Thread satish chandra j
shop.oreilly.com/product/0636920033073.do> (O'Reilly) > Typesafe <http://typesafe.com> > @deanwampler <http://twitter.com/deanwampler> > http://polyglotprogramming.com > > On Mon, Aug 10, 2015 at 7:44 AM, satish chandra j < > jsatishchan...@gmail.com> wrote: &

Re: Spark Cassandra Connector issue

2015-08-10 Thread Dean Wampler
deanwampler <http://twitter.com/deanwampler> http://polyglotprogramming.com On Mon, Aug 10, 2015 at 7:44 AM, satish chandra j wrote: > HI All, > Please help me to fix Spark Cassandra Connector issue, find the details > below > > *Command:* > > dse spark-submit --master

Spark Cassandra Connector issue

2015-08-10 Thread satish chandra j
HI All, Please help me to fix Spark Cassandra Connector issue, find the details below *Command:* dse spark-submit --master spark://10.246.43.15:7077 --class HelloWorld --jars ///home/missingmerch/postgresql-9.4-1201.jdbc41.jar ///home/missingmerch/etl-0.0.1-SNAPSHOT.jar *Error:* WARN 2015

Re: Spark Cassandra connector issue

2014-10-21 Thread Ankur Srivastava
Is this because I am calling a transformation function on an rdd from inside another transformation function? Is it not allowed? Thanks Ankut On Oct 21, 2014 1:59 PM, "Ankur Srivastava" wrote: > Hi Gerard, > > this is the code that may be helpful. > > public class ReferenceDataJoin implements S

Spark Cassandra connector issue

2014-10-21 Thread Ankur Srivastava
Hi, I am creating a cassandra java rdd and transforming it using the where clause. It works fine when I run it outside the mapValues, but when I put the code in mapValues I get an error while creating the transformation. Below is my sample code: CassandraJavaRDD cassandraRefTable = javaFuncti

Spark Cassandra Connector Issue and performance

2014-09-24 Thread pouryas
like to know if people seeing good performance reading from cassandra using spark as oppose to reading data from HDFS. Kind of an open question but would like to see how others are using it. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Cassandra

spark-cassandra-connector issue

2014-08-06 Thread Gary Zhao
Hello I'm trying to modify Spark sample app to integrate with Cassandra, however I saw exception when submitting the app. Anyone knows why it happens? Exception in thread "main" java.lang.NoClassDefFoundError: com/datastax/spark/connector/rdd/reader/RowReaderFactory at SimpleApp.main(SimpleApp.sc