hadoop - 在 hadoop reducer 中检索全局参数返回 null

Question

我为这样的工作设置了一个全局变量：

Configuration conf = new Configuration();   
    Job job = new Job(conf, "new_job"); 
     conf.set("attribute", "value");

我像这样在减速器中访问它，并检查了值：

Configuration conf = context.getConfiguration();
    attribute = conf.get("attribute");
    System.out.println("attribute:"+attribute);

但它的值也打印为 null

空指针异常

当我尝试使用检索到的变量时遇到

属性

稍后在代码中。

请帮助我找出问题所在。

Answer 1

将 conf 传递给 Job 最终会从配置对象中复制属性。您应该在构建作业之前设置属性

Configuration conf = new Configuration();   
conf.set("attribute", "value");
Job job = new Job(conf, "new_job");