Hi All, As I'm running worcount program in flink cluster. and i have created HDFS cluster env to access file sytem. but can you please help how to access the file system from HDFS.
root1@master:~/NAI/Tools/BEAM/Flink_Cluster/rama/flink$ bin/flink run ./examples/streaming/WordCount.jar *--input hdfs://user/wordcount_input.txt *--output hdfs://user/wordcount_output.txt How to provide input file here? [image: Inline image 1] \ Thanks & Regards, Ramanji
