我编写了执行MapReduce流，该流包含Mapper和Reducer的层叠流。
在reduce()方法中，它抛出IllegalArgumentException。如何处理这个exception？
我在类里面写了catch block，为此我创建了JobConf并将其添加到MapReduceFlow constructor。
最佳答案
在级联作业中，可以使用failure traps来执行此操作。从链接上的示例中，它类似于:
flowDef.addTrap( "assertions", trap );
关于hadoop - 如何在级联的MapReduceFlow中处理异常，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18572121/