今天在编写hadoop程序的时候，用到了流的处理。关闭流的时候出现了问题：

代码：

1 FSDataInputStream fsin = fs.open(new Path(filein));

2 FSDataOutputStream fsout = fs.append(new Path(fileout));

3 BufferedReader br = new BufferedReader(new InputStreamReader(fsin));

4 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(fsout));

5 ...

6 br.close();

7 fsin.close();

8 bw.close();

9 fsout.close();

异常：

1 [root@bigdata004 bigdata]# ./bigdataTimer.sh

2 INFO [main] com.sinosoft.bigdata.BigDataTimer.main(227) | -----Timer begin-----

3 INFO [main] com.sinosoft.bigdata.BigDataInit.(70) | bigdata init ...

4 WARN [main] org.apache.hadoop.util.NativeCodeLoader.(62) | Unable to load native-hadoop library for your platform... using builtin-java classes where applicable

5 INFO [main] com.sinosoft.bigdata.BigDataTimer.mergeFile(66) | Finished appending file.

6 INFO [main] com.sinosoft.bigdata.BigDataTimer.mergeFile(68) | deleted the input data path.

7 INFO [main] com.sinosoft.bigdata.BigDataTimer.mergeFile(70) | create the input data path.

8 ERROR [main] org.apache.hadoop.hdfs.DFSClient.closeAllFilesBeingWritten(776) | Failed to close file /user/root/dayfileInput/dayfileIn

9 org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.hdfs.server.namenode.LeaseExpiredException): No lease on /user/root/dayfileInput/dayfileIn: File does not exist. Holder DFSClient_NONMAPREDUCE_-221972347_1 does not have any open files.

原因：关闭处理流br.close();之后，紧接着关闭了与之相关的fsin.close();的节点流。事实上，br.close();会调用fsin.close(); 因此重复关闭了2次fsin.close();最后抛出了异常。

回顾了一下流的知识：

按照流是否直接与特定的地方(如磁盘、内存、设备等)相连，分为节点流和处理流两类。