Mkdir all parent dirs for fs storager

open-gpdb · Aug 15, 2024 · 79ac264 · 79ac264
1 parent f2db008
commit 79ac264
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
 	}