jiapeng 6 years ago
parent
commit
c796bebfd9

+ 3 - 3
src/main/java/com/ekexiu/project/storage/diacrisis/AiCleanTask.java

@ -51,9 +51,9 @@ public class AiCleanTask implements Runnable{
51 51
							ret = ret.trim();
52 52
							if (ret.equals("1")) {
53 53
								aiTaskService.updateTaskState(taskId, 399, null, new AiStrengthenTask(taskId, taskType, aiTaskService));
54
								file = new File(aiTaskService.getDstPath(), taskId);
55
								file = new File(file,"data_desen");
56
								aiTaskService.uploadToHdfs(taskId,file);
54
//								file = new File(aiTaskService.getDstPath(), taskId);
55
//								file = new File(file,"data_desen");
56
//								aiTaskService.uploadToHdfs(taskId,file);
57 57
								return;
58 58
							}
59 59
						}