diff --git a/dfs/ipfs/p2p/p2p.go b/dfs/ipfs/p2p/p2p.go
index 3686db40..e5ea682a 100644
--- a/dfs/ipfs/p2p/p2p.go
+++ b/dfs/ipfs/p2p/p2p.go
@@ -188,6 +188,10 @@ func (ipfs *ipfsP2p) CompleteMultipartUpload(
 			}
 		}
 
+		// cleanup session & cached layer parts
+		ipfs.uploadSession.Del(uploadId)
+		ipfs.uploadParts.Del(uploadId)
+
 		return path.RootCid().String(), nil
 	}