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 ) 。 ????? ??? ??? ??? ??? ??? ??? ?
[email protected]
