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 モードにする必要があります。