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,

Reply via email to