MapReduce의 예외 처리 방법 계단식

Question

및 Reducer 모두 MapReduce 흐름을 실행하는 계단식 흐름을 작성했습니다. reduce() 메서드에서 IllegalArgumentException을 throw합니다. 이것을 처리하는 방법 exception? 나는 동일한 번호로 JobConf를 생성 한 클래스에 catch block을 작성하여 MapReduceFlow constructor에 추가했습니다.

Answer 1

계단식 작업에서는 failure traps을 사용하면됩니다. 링크의 예를 보면 다음과 같습니다.

flowDef.addTrap("assertions", trap);