You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "P. Ramanjaneya Reddy" <ra...@gmail.com> on 2017/08/11 09:31:04 UTC
How to access HDFS file from flink
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
Re: How to access HDFS file from flink
Posted by Aljoscha Krettek <al...@apache.org>.
Hi,
Unfortunately. Inline images do not work on these mailing lists. Also, could you please use the user mailing lists in the future, since the dev mailing lists are meant for discussing the development of Flink.
Best,
Aljoscha
> On 11. Aug 2017, at 11:31, P. Ramanjaneya Reddy <ra...@gmail.com> wrote:
>
>
> 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?
>
>
>
>
> \
>
> Thanks & Regards,
> Ramanji