Try this along with your MapReduce source code

Configuration config = new Configuration();
config.set("fs.defaultFS", "hdfs://IP:port/");
FileSystem dfs = FileSystem.get(config);
Path path = new Path("/tmp/in");

Let me know your thoughts.


-- 
*Thanks & Regards *


*Unmesha Sreeveni U.B*
*Hadoop, Bigdata Developer*
*Center for Cyber Security | Amrita Vishwa Vidyapeetham*
http://www.unmeshasreeveni.blogspot.in/

Reply via email to