Глобальное свойство Hadoop Conf.Set / Conf.Get в Cleanup ()?

Question

Я пытаюсь использовать глобальные переменные в Hadoop с помощью методов Conf.set () и Context.getConfiguration (). Get ().

Однако, похоже, что они не работают внутри метода очистки, который я использую - хотя я могу использовать свойства в Mapper и Reducer. Это странное или нормальное поведение?

Есть ли другой способ распространения значения переменной в MapReduce Jobs и внутри метода очистки задания hadoop.

Answer 1

Параметры, заданные в классе Job, правильно поступают в метод очистки.

В основном методе указано следующее

Configuration conf = new Configuration();
conf.set("test", "123");
Job job = new Job(conf);

Ниже приведен метод очистки Mapper #

protected void cleanup(Context context) throws IOException,
    InterruptedException {

    Configuration conf = context.getConfiguration();
    String param = conf.get("test");
    System.out.println("clean p--> param = " + param);

}

O / P вышеупомянутого:

clean p -> param = 123

Проверьте код еще раз.Кстати, я протестировал его с выпуском 0,21.