Hadoop MultipleOutputs 체크섬

Question

Reducer에서 여러 파일을 작성하는 데 MultipleOutputs를 사용하고 있습니다. 그러나 대상 폴더를 조사 할 때 파일이 성공적으로 기록되지만 체크섬 파일은 비어 있습니다 (생성되었지만). 체크섬을 쓰는 MultipleOutputs를 만들 수있는 방법이 있습니까?

I 감속기에 반대 '실행'방법

MultipleOutputs.addNamedOutput(job, "fld1", 
    TextOutputFormat.class, 
    Text.class, Text.class); 
    ... 

의 이름 출력을 추가하고 MultipleOutputs에 쓰고 :

output = new MultipleOutputs(context); 
... 
output.write("fld1", key, new Text(Arrays.toString(myData))); 

어떤 아이디어가?

Answer 1

쓰기가 완료되면 MultipleOutputs 객체를 명시 적으로 닫아야합니다. 다음 호출은 문제를 해결합니다. output.close()