Re: CassandraSQLContext throwing NullPointer Exception

Ted, I am using spark 1.3.0 and running the code in YARN mode. Here is the code.. object streaming { def main(args:Array[String]) { val conf = new SparkConfst conf..setMaster("yarn-client") conf.setAppName("SimpleApp") conf.set("spark.cassandra.coonection.host","") val sc = new

CassandraSQLContext throwing NullPointer Exception

Hi All, I am trying to use dataframes (which contain data from cassandra) in rdd.foreach. This is throwing the following exception: Is CassandraSQLContext accessible within executor 15/09/28 17:22:40 ERROR JobScheduler: Error running job streaming job 144344116 ms.0

Re: CassandraSQLContext throwing NullPointer Exception

Which Spark release are you using ? Can you show the snippet of your code around CassandraSQLContext#sql() ? Thanks On Mon, Sep 28, 2015 at 6:21 AM, Priya Ch wrote: > Hi All, > > I am trying to use dataframes (which contain data from cassandra) in > rdd.foreach.