title: Cassandra Spark job submission
body: <p>I am a relative newbie to spark/cassandra.  As such I have a basic question.  I have compiled an uber jar and loaded it to my spark/cassandra server.  Now I am in a pickle, how do I run it via the cassandra (DSE) enviornment?  I know the spark shell command is "dse spark-submit" but when I try to do a "dse spark-submit" I get a "NullPointerException"</p>
  
  <p>Here is the full output:</p>
  
  <pre><code>Exception in thread "main" java.lang.NullPointerException
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke(Method.java:606)
      at org.apache.spark.deploy.SparkSubmit$.launch(SparkSubmit.scala:328)
      at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:75)
      at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
  </code></pre>
  
  <p>The program code is very basic and has been proven to work in the spark shell
      package xxx.seaoxxxx</p>
  
  <pre><code>import com.datastax.spark.connector._
  import org.apache.spark.{SparkConf, SparkContext}
  
  
  class test {
    def main(args: Array[String]){
      val conf = new SparkConf(true).set("spark.cassandra.connection.host", "xx.xxx.xx.xx")
        .setAppName("Seasonality")
  
      val sc = new SparkContext("spark://xx.xxx.xx.xx:7077", "Season", conf)
  
      val ks = "loadset"
      val incf =  "period"
  
      val rdd = sc.cassandraTable(ks, incf)
      rdd.count
      println("done with test")
      sc.stop()
    }
  }
  </code></pre>
  
  <p>The spark-submit code is as follows:
      dse spark-submit \
      --class xxx.seaoxxxx.test \
      --master spark://xxx.xx.x.xxx:7077 \
      /home/ubuntu/spark/Seasonality_v6-assembly-1.0.1.jar  100</p>
  
  <p>Thanks,</p>
  
  <p>Eric</p>