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 <deepesh.maheshwar...@gmail.com>
wrote:
> 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<String> words=lines.flatMap(new FlatMapFunction<String, String>()
> {
> private static final long serialVersionUID =
> -2042174881679341118L;
>
> @Override
> public Iterable<String> call(String t) throws Exception {
>
> // Mark Debug Point here, it doesn't stop here.
>
> return Lists.newArrayList(SPACE.split(t));
> }
> });
>
> Please suggest how can i saw the in-between data values.
>
> Regards,
> Deepesh
Eugene Morozov
fathers...@list.ru
