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
