Hi Will,

for HDFS, you can try to define the HADOOP_CONF_DIR env variable.

Regards
JB

On 06/14/2017 12:35 AM, Will Walters wrote:
JB,

I'm trying to run the Word Count example as shown on the website. If I define the path to hdfs-site.xml in the Flink config, I get an error saying "Unable to find registrar for HDFS." If I do not, it is unable to find the specified file.

-Will


On Tuesday, June 13, 2017 12:23 PM, Jean-Baptiste Onofré <[email protected]> 
wrote:


Hi,

which sample do you try ?

For HDFS, how did you define the location of the hdfs-site.xml ?

Regards
JB

On 06/13/2017 08:31 PM, Will Walters wrote:
 > Hello,
 >
 > I am attempting to run the Beam quickstart with Flink on a Yarn cluster.
 > However, I cannot find a file path which gets Flink to recognize the input 
file.
 > I have tried local, absolute, and hdfs filepaths, and none of them have 
seemed
 > to work. Does anyone have advice about what form the filepaths should be in?
 >
 > Thank you,
 > Will Walters.


--
Jean-Baptiste Onofré
[email protected] <mailto:[email protected]>
http://blog.nanthrax.net <http://blog.nanthrax.net/>
Talend - http://www.talend.com <http://www.talend.com/>




--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com

Reply via email to