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

kadbb459 于 2021-05-30 发布在 Hadoop

关注(0)|答案(1)|浏览(415)

我为job设置了一个全局变量，如下所示：

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
nullpointerexception异常
在尝试使用检索到的变量时遇到
属性
代码后面。
请帮我找出哪里出了问题。

1条答案

将conf传递到作业中最终会从配置对象复制属性。在构造作业之前，应该设置属性

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