Sometimes resource file will fail to load In ET PythonParallelExt; wi…

…ll pick by v1.1.7.1
ilibx · Jan 16, 2019 · 6fcc34f · 6fcc34f
1 parent 0592f51
commit 6fcc34f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/streamingpro-commons/src/main/java/streaming/common/HDFSOperator.scala b/streamingpro-commons/src/main/java/streaming/common/HDFSOperator.scala
@@ -148,7 +148,7 @@ object HDFSOperator {
     fs.copyFromLocalFile(new Path(tempLocalPath),
       new Path(path))
     if (cleanSource) {
-      FileUtils.forceDelete(new File(tempLocalPath))
+      FileUtils.deleteQuietly(new File(tempLocalPath))
     }
 
   }
@@ -157,7 +157,7 @@ object HDFSOperator {
     val fs = FileSystem.get(new Configuration())
     val tmpFile = new File(tempLocalPath)
     if (tmpFile.exists()) {
-      FileUtils.forceDelete(tmpFile)
+      FileUtils.deleteQuietly(tmpFile)
     }
     fs.copyToLocalFile(new Path(path), new Path(tempLocalPath))
   }