diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java index fdae3bef18921008a4c12da12e8971186bd65c86..d330601df652a68faf4426edfb4fe8a2679f7c74 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java @@ -600,6 +600,11 @@ public class ResourcesServiceImpl extends BaseServiceImpl implements ResourcesSe org.apache.dolphinscheduler.api.utils.FileUtils.copyFile(file, localFilename); HadoopUtils.getInstance().copyLocalToHdfs(localFilename, hdfsFilename, true, true); } catch (Exception e) { + try { + FileUtils.deleteFile(localFilename); + } catch (IOException ex) { + logger.error("delete local tmp file:{} error", localFilename, ex); + } logger.error(e.getMessage(), e); return false; } diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/FileUtils.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/FileUtils.java index 8c45c21c01ff25442be04d95f82acc3423d84e87..32e85986b100176082b73fa94ebb5ef0371a64d2 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/FileUtils.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/FileUtils.java @@ -383,7 +383,10 @@ public class FileUtils { * @throws IOException in case deletion is unsuccessful */ public static void deleteFile(String filename) throws IOException { - org.apache.commons.io.FileUtils.forceDelete(new File(filename)); + File file = new File(filename); + if (file.exists()) { + org.apache.commons.io.FileUtils.forceDelete(file); + } } /**