java - 通过汇总警告来调试Pig UDF

Question

我试图在我的Pig UDF中使用warn()方法，如下所示:

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脚本时，在工作结束时再也看不到这些警告。

如何配置Pig以查看汇总警告？

Answer 1

因此，我发现在本地模式下，您将永远不会看到汇总的警告。您需要处于MapReduce模式才能看到它们!