hadoop - Cascading的MapReduceFlow中如何处理异常

Question

我已经编写了级联流，它执行MapReduce包含Mapper和的流Reducer。在reduce()方法中，它抛出IllegalArgumentException. 如何处理exception？我catch block在课堂上写过我为它创建 JobConf 并将其添加到MapReduceFlow constructor.

Answer 1

在您的级联作业中，您可以使用故障陷阱来执行此操作。从链接上的示例中，它类似于：

flowDef.addTrap( "assertions", trap );