flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "P. Ramanjaneya Reddy" <ramanji...@gmail.com>
Subject How to access HDFS file from flink
Date Fri, 11 Aug 2017 09:31:04 GMT
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,

  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message