Deepesh,
you have to call an action to start actual processing.
words.count() would do the trick.
On 05 Aug 2015, at 11:42, Deepesh Maheshwari
wrote:
> Hi,
>
> As spark job is executed when you run start() method of JavaStreamingContext.
> All the job like map, flatMap is already defined ea
Hi,
As spark job is executed when you run start() method of
JavaStreamingContext.
All the job like map, flatMap is already defined earlier but even though
you put breakpoints in the function ,breakpoint doesn't stop there , then
how can i debug the spark jobs.
JavaDStream words=lines.flatMap(new
