或者如果你想在不写配置文件
Configuration config = new Configuration(true);
config.set("fs.default.name","hdfs://192.168.200.135:9000");
可以这样写,但是 Configuration config = new Configuration(false); 不要用false 。
使用false就会加载默认配置文件。
出错地点在:
private static FileSystem createFileSystem(URI uri, Configuration conf
) throws IOException {
Class clazz = conf.getClass("fs." + uri.getScheme() + ".impl", null); // 这个因为没有加载默认的配置文件为空,所以下边在判断的时候就出错了。
if (clazz == null) {
throw new IOException("No FileSystem for scheme: " + uri.getScheme());
}
FileSystem fs = (FileSystem)ReflectionUtils.newInstance(clazz, conf);
fs.initialize(uri, conf);
return fs;
}
package org.apache.hadoop.fs.FileSystem 文件中。 |