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