调试猪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运行我的猪剧本，我从来没有看到这些在工作结束时汇总警告。

如何配置pig以查看聚合警告？

Answer 1

所以我想通了，在本地模式下，你永远不会看到聚合警告。你需要进入MapReduce模式才能看到它们！