qqq

pom.xml

    <packaging>war</packaging>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <maven.war.filteringDeploymentDescriptors>true</maven.war.filteringDeploymentDescriptors>
        <maven.tomcat.path>/</maven.tomcat.path>
    </properties>

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

	public void setRemoteUrl(String remoteUrl) {
		System.setProperty("HADOOP_USER_NAME", "hadoop");
		this.remoteUrl = remoteUrl;
		configuration.set("fs.default.name", this.remoteUrl);
		try {
	}
	
	public void upload(String path,File src) throws IOException{
		Path dstPath = new Path(root,path);
		if(src.exists() && src.isDirectory()){
			Path dst  =  new Path(root,path);
			if(this.dfs.exists(dst)){
				if(!this.dfs.delete(dst,true)){
					throw new IOException("delete "+configuration.get("fs.default.name")+path.toString()+" error");
			if(!this.dfs.exists(dstPath)){
				if(!this.dfs.mkdirs(dstPath)){
					throw new IOException("mkdir "+configuration.get("fs.default.name")+"/"+path+" error");
				}
			}
			if(!this.dfs.mkdirs(dst)){
				throw new IOException("mkdir "+configuration.get("fs.default.name")+path.toString()+" error");
			
			
			for(File file:src.listFiles()){
				Path dst = new Path(dstPath,file.getName());
				if(this.dfs.exists(dst)){
					if(!this.dfs.delete(dst,true)){
						throw new IOException("delete "+configuration.get("fs.default.name")+"/"+path+"/"+file.getName()+" error");
					}
				}
				this.dfs.copyFromLocalFile(new Path(src.getAbsolutePath()), dst);
			}
			this.dfs.copyFromLocalFile(new Path(src.getAbsolutePath()), dst);
		}
		
	}
	public static void main(String args[]) throws Exception{
		HdfsService service = new HdfsService();
		service.setRemoteUrl("hdfs://39.97.161.48:9000");
		service.upload("11",new File("/ekexiu/storage_asd/dst/a"));
		service.upload("25",new File("/ekexiu/storage_asd/task/result/test/data_desen"));
		
		System.out.println("11111111111111111111111111111111");
	}
}

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

		File file = new File(aiTaskService.getDstPath(), taskId);
		file = new File(file,"data");
			try {
				URL u = new URL("http://127.0.0.1:5001//desensitize?pi=" + file.getAbsolutePath());
				URL u = new URL("http://127.0.0.1:5001/desensitize?pi=" + file.getAbsolutePath());
				HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
				if (httpURLConnection.getResponseCode() == 200) {
					InputStream in = httpURLConnection.getInputStream();