Mkdir all parent dirs for fs storager (#51)

open-gpdb · Aug 15, 2024 · b89afcb · b89afcb
1 parent f2db008
commit b89afcb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/storage/filestorage.go b/pkg/storage/filestorage.go
@@ -50,7 +50,10 @@ func (s *FileStorageInteractor) ListPath(prefix string) ([]*ObjectInfo, error) {
 }
 
 func (s *FileStorageInteractor) PutFileToDest(name string, r io.Reader) error {
-	file, err := os.Create(path.Join(s.cnf.StoragePrefix, name))
+	fPath := path.Join(s.cnf.StoragePrefix, name)
+	fDir := path.Dir(fPath)
+	os.MkdirAll(fDir, 0700)
+	file, err := os.Create(fPath)
 	if err != nil {
 		return err
 	}