fix:the HdfsStorage can not delete checkpoint file apache#5046 (apach…

…e#5054)
liunaijie · Jul 13, 2023 · 9c8a8c8 · 9c8a8c8
1 parent 9df49f2
commit 9c8a8c8
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...e-hdfs/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/HdfsStorage.java b/...e-hdfs/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/HdfsStorage.java
@@ -283,7 +283,9 @@ public synchronized void deleteCheckpoint(String jobId, String pipelineId, Strin
                     if (pipelineId.equals(getPipelineIdByFileName(fileName))
                             && checkpointId.equals(getCheckpointIdByFileName(fileName))) {
                         try {
-                            fs.delete(new Path(fileName), false);
+                            fs.delete(
+                                    new Path(path + DEFAULT_CHECKPOINT_FILE_PATH_SPLIT + fileName),
+                                    false);
                         } catch (Exception e) {
                             log.error(
                                     "Failed to delete checkpoint {} for job {}, pipeline {}",
@@ -311,7 +313,9 @@ public void deleteCheckpoint(String jobId, String pipelineId, List<String> check
                     if (pipelineId.equals(getPipelineIdByFileName(fileName))
                             && checkpointIdList.contains(checkpointIdByFileName)) {
                         try {
-                            fs.delete(new Path(fileName), false);
+                            fs.delete(
+                                    new Path(path + DEFAULT_CHECKPOINT_FILE_PATH_SPLIT + fileName),
+                                    false);
                         } catch (Exception e) {
                             log.error(
                                     "Failed to delete checkpoint {} for job {}, pipeline {}",