You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "namesuperwood@gmail.com" <na...@gmail.com> on 2014/06/03 12:50:23 UTC

a bug for flume-ng 4.5






hi ?all? ? In ?file AbstractHDFSWriter.java ?, the definition of function ?"closeHDFSOutputStream" ?? ? as follow ? ?which can throw IOexception on some err.? ?? ??? ??? ??? ??? ??? ??protected void closeHDFSOutputStream(OutputStream outputStream)?? ?? ??? ??? ??? ??? ??? ??throws IOException{? ?But at the end of this function ?, it catch the IOexception and never rethrow it !!!?? ??? ??? ??? ??? ??? ? ?catch (IOException e) {?? ??? ??? ??? ??? ??? ??? ?? ??logger.error("Unable to close HDFS file: '"  + destPath + "'", e);? ? ? ? ? ? ? ? ? ? ? ? ? }
? ? The funciton "closeHDFSOutputStream" ? is called by hdfsSink。 The bug ?make ? BucketWrite.close function ?always ? looks right and can?BucketWrite.rename?。 And It result in the status of ? files writed by flume in hdfs ?is openforwrite ?(but it is renamed succ ) 。 ????? ??? ??? ??? ??? ??? ??? ?


namesuperwood@gmail.com