configuration - Hadoop Configuration.addDefaultResource() 不工作

Question

我的以下代码没有产生预期的输出:

public static void main(String[] args) throws MalformedURLException {

    Configuration.addDefaultResource("/home/some_user/conf.xml");
    Configuration conf = new Configuration();
    System.out.println(conf);
    System.out.println(conf.get("color"));
    assertThat(conf.get("color"), is("yellow"));
}

属性color在conf.xml文件中设置如下:

<property>
        <name>color</name>
        <value>yellow</value>
        <description>Color</description>
</property>

看起来文件 conf.xml 没有合并到默认配置中。

Configuration.addDefaultResource(String param) 的文档说参数应该在类路径中。当我已经为程序提供完整的绝对路径时，我不明白如何将文件添加到类路径。

Answer 1

第一个观察:我不知道您使用的是哪个版本的 hadoop，但 addDefaultResource() 已被弃用很长时间。

在更高版本的 Hadoop 中，完成您想要的操作的标准方法是:

Configuration conf = new Configuration()
conf.addResource("path/to/file");
...

关于类路径问题，您只需将配置文件放在类路径中即可。所以你必须发现类路径是什么(它要么是一个环境变量，要么是你用 -classpath 选项设置的)。如果您没有使用 -classpath 选项并且没有类路径环境变量，那么它会自动设置为当前目录 (".")