myeclipse中建web项目上传文件到hadoop，出现文件上传上去了，但是文件大小为0或小于当前文件解决方案，

myeclipse中建web项目上传文件到hadoop，出现文件上传上去了，但是文件大小为0或小于当前文件解决方案，

request.setCharacterEncoding("UTF-8");
Long start = System.currentTimeMillis();
try {
if (ServletFileUpload.isMultipartContent(request)) {
DiskFileItemFactory dff = new DiskFileItemFactory();// 创建该对象
dff.setRepository(tmpDir);// 指定上传文件的临时目录
dff.setSizeThreshold(1024000);// 指定在内存中缓存数据大小,单位为byte
ServletFileUpload sfu = new ServletFileUpload(dff);// 创建该对象


// sfu.setFileSizeMax(5000000);// 指定单个上传文件的最大尺寸
// sfu.setSizeMax(10000000);// 指定一次上传多个文件的总尺寸
FileItemIterator fii = sfu.getItemIterator(request);// 解析request
// 请求,并返回FileItemIterator集合
while (fii.hasNext()) {
FileItemStream fis = fii.next();// 从集合中获得一个文件流
if (!fis.isFormField() && fis.getName().length() > 0) {// 过滤掉表单中非文件域
System.out.println("ok:" + fis.getName());
/*String fileName = ReplaceBadCharOfFileName(fis
.getName());*/
String fileName = fis
.getName();
System.out.println(fileName);
BufferedInputStream in = new BufferedInputStream(
fis.openStream());// 获得文件输入流
String dst = "hdfs://192.168.0.16:9000/" + fileName;

Configuration conf = new Configuration();
// 获得hadoop系统的连接
FileSystem fs = FileSystem.get(URI.create(dst), conf);
// out对应的是Hadoop文件系统中的目录
OutputStream out = fs.create(new Path(dst));
IOUtils.copyBytes(in, out, 4096, false);// 4096是4k字节
out.flush();
out.close();
fs.close();
System.out.println("success");
System.out.println(System.currentTimeMillis() - start);
}
}
response.getWriter().println("File upload successfully!!!");// 终于成功了,还不到你的上传文件中看看,你要的东西都到齐了吗
}
} catch (Exception e) {
e.printStackTrace();

}

一开始没有添加out.flush();out.close();fs.close();故导致了上面的情况