Hi, Im trying to stream data to Haddop as a csv . In batch processing i can use HadoopOutputFormat like that ( example/WordCount.java <https://github.com/apache/flink/blob/master/flink-connectors/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapreduce/example/WordCount.java> ).
I cant find any way to integrate bucktsink and HaddopOutputFormat and im not sure if its the correct way ? Any suggestion how can i stream csv to Hadoop. thanks, Miki
