エラー: java.lang.RuntimeException: PipeMapRed.waitOutputThreads(): org.apache.hadoop.streaming.PipeMapRed.mapRedFinished の org.apache.hadoop.streaming.PipeMapRed.waitOutputThreads(PipeMapRed.java:320) でサブプロセスがコード 1 で失敗しました(PipeMapRed.java:533) org.apache.hadoop.streaming.PipeMapper.close(PipeMapper.java:130) org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:61) org.apache. hadoop.streaming.PipeMapRunner.run(PipeMapRunner.java:34) の org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430) の org.apache.hadoop.mapred.MapTask.run(MapTask.java: 342) org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:167) で java.security.AccessController.doPrivileged(ネイティブメソッド) で javax.security.auth.Subject.doAs(Subject.java:415) ) 組織で。org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:162) の apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)