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 ) 。 ????? ??? ??? ??? ??? ??? ??? ? namesuperw...@gmail.com