Re: HDFS Clustering

Posted by Márton Balassi-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/HDFS-Clustering-tp786p788.html

Hey,

Just add the the right prefix pointing to your hdfs filepath:

bin/flink run -v flink-java-examples-*-WordCount.jar hdfs://hostname:port/PATH/TO/INPUT hdfs://hostname:port/PATH/TO/OUTPUT

Best,

Marton

On Tue, Feb 24, 2015 at 11:13 AM, Giacomo Licari <[hidden email]> wrote:

Hi guys,
I'm Giacomo from Italy, I'm newbie with Flink.

I setted up a cluster with Hadoop 1.2 and Flink.

I would like to ask to you how to run the WordCount example taking the input file from hdfs (example myuser/testWordCount/hamlet.

txt) and put the output also inside hdfs (example myuser/testWordCount/output.txt).

I successfully run the example on my local filesystem, I would like to test it with HDSF.

Thanks a lot guys,
Giacomo