在Map或reduce中使用multipleOutput来进行异常存储:
1 2 3 4 5 6 7 8 9
|
try{ ... ... context.write(newKey,newValue); }catch(Exception e){ multipleOutput.write(new Text( null == e.getMessage()? ("error:"): e.getMessage),new Text(value.toString()),"_error/part"); e.printStackTrace(); }
|
近期评论