File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
java/openmldb-taskmanager/src/main/scala/com/_4paradigm/openmldb/taskmanager Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -203,8 +203,7 @@ object JobInfoManager {
203203 val offlineTableInfo = tableInfo.getOfflineTableInfo
204204
205205 val filePath = offlineTableInfo.getPath
206- if (offlineTableInfo.getDeepCopy) {
207-
206+ if (filePath.nonEmpty) {
208207 if (filePath.startsWith(" file://" )) {
209208 val dir = new File (filePath.substring(7 ))
210209 logger.info(s " Try to delete the path ${filePath.substring(7 )}" )
@@ -217,7 +216,7 @@ object JobInfoManager {
217216 throw new Exception (s " Get unsupported file path: $filePath" )
218217 }
219218 } else {
220- logger.info(s " Do not delete file $filePath for non deep copy data " )
219+ logger.info(s " Do not delete for empty hard path " )
221220 }
222221 }
223222
You can’t perform that action at this time.
0 commit comments