[Hotfix][Zeta] Fix checkpoint storage namespace

apache · Mar 4, 2023 · d346ac3 · d346ac3
1 parent 533ff2c
commit d346ac3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...in/java/org/apache/seatunnel/engine/checkpoint/storage/api/AbstractCheckpointStorage.java b/...in/java/org/apache/seatunnel/engine/checkpoint/storage/api/AbstractCheckpointStorage.java
@@ -115,6 +115,9 @@ public PipelineState deserializeCheckPointData(byte[] data) throws IOException {
 
     public void setStorageNameSpace(String storageNameSpace) {
         if (storageNameSpace != null) {
+            if (!storageNameSpace.endsWith(DEFAULT_CHECKPOINT_FILE_PATH_SPLIT)) {
+                storageNameSpace = storageNameSpace + DEFAULT_CHECKPOINT_FILE_PATH_SPLIT;
+            }
             this.storageNameSpace = storageNameSpace;
         }
     }