MapReduce 动态设立 namenode HDFS 的URI

2012-06-26

MapReduce 动态设置 namenode HDFS 的URI开发MapReduce程序一直都是在namenode 那台pc上用eclipse 直接运

MapReduce 动态设置 namenode HDFS 的URI
开发MapReduce程序一直都是在namenode 那台pc上用eclipse 直接运行，没有任何问题
今天在一台namenode上用eclipse 编译一M/R小程序，结果死活都是

?baidu google了半天 也没找出如何在MapReduce之前动态设置 DFS的URI?
无奈之下 只能求助与 M/R 源代码 发现 org.apache.hadoop.fs.FileSystemString[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();System.out.println(FileSystem.getDefaultUri(conf)); FileSystem.setDefaultUri(conf, new URI("hdfs://gucas-s2:9000")); //动态设置 dfs uriSystem.out.println(FileSystem.getDefaultUri(conf));if(otherArgs.length != 2){    System.err.println("Usage: invertedindex <in> <out>");    System.exit(2);}Job job = new Job(conf, "InvertedIndex");job.setJarByClass(InvertedIndex.class);
??一定要在Job job = new Job(conf, "InvertedIndex"); 之前设置
?FileSystem.setDefaultUri(conf, new URI("hdfs://gucas-s2:9000")); //动态设置 dfs uri
否则无效

热点排行

开源软件

MapReduce 动态设立 namenode HDFS 的URI