处理Filesystem closed事件

 final Configuration conf = new Configuration();

    
 final FileSystem fs = FileSystem.get(URI.create(hdfsFile), conf);
    
 final Path path = new Path(hdfsFile);
    
 if (fs.exists(path)) {
    
 	final FSDataInputStream is = fs.open(path);
    
 	final FileStatus stat = fs.getFileStatus(path);
    
 	final byte[] buffer = new byte[Integer.parseInt(String.valueOf(stat.getLen()))];
    
 	is.readFully(0, buffer);
    
 	is.close();
    
 	fs.close();
    
 	return buffer;
    
 } else {
    
 	throw new Exception("the file is not found .");
    
 }