Spark record delimiter definition

gistfile1.java

When I run above codes in spark-shell, I got the following errors:

    scala> val job = new Job(sc.hadoopConfiguration)
    warning: there were 1 deprecation warning(s); re-run with -deprecation for details
    java.lang.IllegalStateException: Job in state DEFINE instead of RUNNING
      at org.apache.hadoop.mapreduce.Job.ensureState(Job.java:283)
      at org.apache.hadoop.mapreduce.Job.toString(Job.java:452)
      at scala.runtime.ScalaRunTime$.scala$runtime$ScalaRunTime$$inner$1(ScalaRunTime.scala:324)
      at scala.runtime.ScalaRunTime$.stringOf(ScalaRunTime.scala:329)
      at scala.runtime.ScalaRunTime$.replStringOf(ScalaRunTime.scala:337)
      at .<init>(<console>:10)
      at .<clinit>(<console>)
      at $print(<console>)
      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.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:788)
      at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1056)
      at org.apache.spark.repl.SparkIMain.loadAndRunReq$1(SparkIMain.scala:614)
      at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:645)
      at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:609)
      at org.apache.spark.repl.SparkILoop.reallyInterpret$1(SparkILoop.scala:796)
      at org.apache.spark.repl.SparkILoop.interpretStartingWith(SparkILoop.scala:841)
      at org.apache.spark.repl.SparkILoop.command(SparkILoop.scala:753)
      at org.apache.spark.repl.SparkILoop.processLine$1(SparkILoop.scala:601)
      at org.apache.spark.repl.SparkILoop.innerLoop$1(SparkILoop.scala:608)
      at org.apache.spark.repl.SparkILoop.loop(SparkILoop.scala:611)
      at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply$mcZ$sp(SparkILoop.scala:936)
      at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply(SparkILoop.scala:884)
      at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply(SparkILoop.scala:884)
      at scala.tools.nsc.util.ScalaClassLoader$.savingContextLoader(ScalaClassLoader.scala:135)
      at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:884)
      at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:982)
      at org.apache.spark.repl.Main$.main(Main.scala:31)
      at org.apache.spark.repl.Main.main(Main.scala)
      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:303)
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:55)
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)

How to fix this "java.lang.IllegalStateException: Job in state DEFINE instead of RUNNING" problem?

I found [this post](http://mail-archives.apache.org/mod_mbox/hadoop-common-user/201210.mbox/%3CCAOcnVr38koxM5rw-3TLnrRuA41fBcbz8MbRcfp5CMFLNv3eCyg@mail.gmail.com%3E).
It suggest to using "submit your job via submit() or waitForCompletion()", but I don't know how to add them in spark-shell.

Thanks.