Отладка Pig UDF Агрегируя предупреждения

Question

Я пытаюсь использовать метод предупредить() в моих Свинье UDF как это:

public class MyUDF extends EvalFunc<Tuple> { 

    public Tuple exec(Tuple input) throws IOException { 

     boolean condition = true;   
     while(condition) { 
      // Some business logic 
      warn("There was a problem", PigWarning.UDF_WARNING_1); 
     } 
    } 

} 

Когда я запускаю мою свинью скрипт, используя эту UDF локально, я никогда не видел эти предупреждает агрегат в конце задания.

Как настроить свиньи, чтобы увидеть агрегированное предупреждение?

Answer 1

Итак, я понял, что в локальном режиме вы никогда не увидите агрегированных предупреждений. Вы должны быть в режиме MapReduce, чтобы увидеть их!