I am running in yarn-client mode and trying to execute network word count
example. When I connect through nc I see the following in spark app logs:
Exception in thread "main" java.lang.AssertionError: assertion failed: The
checkpoint directory has not been set. Please use
StreamingContext.checkpoint() or SparkContext.checkpoint() to set the
checkpoint directory.
at scala.Predef$.assert(Predef.scala:179)
at
org.apache.spark.streaming.dstream.DStream.validate(DStream.scala:183)
at
org.apache.spark.streaming.dstream.DStream$$anonfun$validate$10.apply(DStream.scala:229)
at
org.apache.spark.streaming.dstream.DStream$$anonfun$validate$10.apply(DStream.scala:229)
at scala.collection
