fix: drop non empty offline path (#3654)

4paradigm · Dec 8, 2023 · 0c2592d · 0c2592d
1 parent c081f28
commit 0c2592d
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...nmldb-taskmanager/src/main/scala/com/_4paradigm/openmldb/taskmanager/JobInfoManager.scala b/...nmldb-taskmanager/src/main/scala/com/_4paradigm/openmldb/taskmanager/JobInfoManager.scala
@@ -203,8 +203,7 @@ object JobInfoManager {
       val offlineTableInfo = tableInfo.getOfflineTableInfo
 
       val filePath = offlineTableInfo.getPath
-      if(offlineTableInfo.getDeepCopy) {
-
+      if(filePath.nonEmpty) {
         if (filePath.startsWith("file://")) {
           val dir = new File(filePath.substring(7))
           logger.info(s"Try to delete the path ${filePath.substring(7)}")
@@ -217,7 +216,7 @@ object JobInfoManager {
           throw new Exception(s"Get unsupported file path: $filePath")
         }
       } else {
-        logger.info(s"Do not delete file $filePath for non deep copy data")
+        logger.info(s"Do not delete for empty hard path")
       }
     }