11111

src/main/java/com/ekexiu/project/hdfs/HdfsService.java

//	private Configuration configuration = new Configuration();
//	private DistributedFileSystem dfs;
//	private Path root = new Path("/");
//	private String remoteUrl;
	private String remoteUrl;
//	
//
//
//		this.root = new Path(rootPath);
//	}
//	
//	public String getRemoteUrl() {
//		return remoteUrl;
//	}
	public String getRemoteUrl() {
		return remoteUrl;
	}
//
//
//	public void setRemoteUrl(String remoteUrl) {
	public void setRemoteUrl(String remoteUrl) {
//		System.setProperty("HADOOP_USER_NAME", "hadoop");
//		this.remoteUrl = remoteUrl;
//		configuration.set("fs.default.name", this.remoteUrl);
//		} catch (IOException e) {
//			throw new RuntimeException(e);
//		}
//	}
	}
	
	public void upload(String path,File src) throws IOException{
//		byte[] buffer = new byte[8192];

src/main/java/com/ekexiu/project/storage/diacrisis/AiTaskService.java

	   
	   for(String f:file){
		   int idx = f.indexOf('.');
		   if(idx!=16){
		   if(idx!=32){
			   throw new IllegalArgumentException("invalid param file");
		   }
		   File taskSrc = new File(this.uploadPath,f.substring(0,16));
		   File taskDst = new File(path,f.substring(17));
		   File taskSrc = new File(this.uploadPath,f.substring(0,32));
		   File taskDst = new File(path,f.substring(33));
		   InputStream in = new FileInputStream(taskSrc);
		   try{
			  OutputStream os = new FileOutputStream(taskDst) ;