I am getting multiple empty files for streaming output for each interval. To Avoid this I tried
kStream.foreachRDD(new VoidFunction2<JavaRDD<String>,Time>(){
*public void call(JavaRDD<String> rdd,Time time) throws Exception {
if(!rdd.isEmpty()){
rdd.saveAsTextFile("filename_"+time.milliseconds()+".csv");
} }*
This prevents writing of empty files. However this appends line after one
another by removing new lines. All lines are merged.
How do I retain my new line?
Thanks
