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