Issue with Spark Streaming with checkpointing in Spark 2.0

} else { streamingContext.awaitTermination() } } } Thanks, Arijit

Understanding code/closure shipment to Spark workers‏

code path to help me understand this. Thanks, Arijit