Issue with Spark Streaming with checkpointing in Spark 2.0

2016-10-07 Thread Arijit
} else { streamingContext.awaitTermination() } } } Thanks, Arijit

RE: Understanding code/closure shipment to Spark workers‏

2015-10-14 Thread Arijit
the closures are serialized and shipped. Maybe I am missing something. Thanks again, Arijit Date: Thu, 8 Oct 2015 10:26:55 -0700 Subject: Re: Understanding code/closure shipment to Spark workers‏ From: gatorsm...@gmail.com To: arij...@live.com CC: dev@spark.apache.org Hi, Arijit, The code flow

Understanding code/closure shipment to Spark workers‏

2015-10-07 Thread Arijit
code path to help me understand this. Thanks, Arijit