add hdfs to resource
This commit is contained in:
parent
9b66e7edf2
commit
07740003b8
@ -1 +0,0 @@
|
|||||||
foler used to hold generated class files
|
|
||||||
@ -51,6 +51,7 @@ public class Client {
|
|||||||
*/
|
*/
|
||||||
private Client() throws IOException {
|
private Client() throws IOException {
|
||||||
conf.addResource(new Path(System.getenv("HADOOP_CONF_DIR") +"/core-site.xml"));
|
conf.addResource(new Path(System.getenv("HADOOP_CONF_DIR") +"/core-site.xml"));
|
||||||
|
conf.addResource(new Path(System.getenv("HADOOP_CONF_DIR") +"/hdfs-site.xml"));
|
||||||
dfs = FileSystem.get(conf);
|
dfs = FileSystem.get(conf);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -169,7 +170,6 @@ public class Client {
|
|||||||
}
|
}
|
||||||
this.initArgs(args);
|
this.initArgs(args);
|
||||||
// Create yarnClient
|
// Create yarnClient
|
||||||
YarnConfiguration conf = new YarnConfiguration();
|
|
||||||
YarnClient yarnClient = YarnClient.createYarnClient();
|
YarnClient yarnClient = YarnClient.createYarnClient();
|
||||||
yarnClient.init(conf);
|
yarnClient.init(conf);
|
||||||
yarnClient.start();
|
yarnClient.start();
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user