[HWORKS-912] 3.5 append (#1455)

logicalclocks · Jan 16, 2024 · 256d503 · 256d503
1 parent b9ae379
commit 256d503
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/hopsworks-common/src/main/java/io/hops/hopsworks/common/upload/UploadController.java b/hopsworks-common/src/main/java/io/hops/hopsworks/common/upload/UploadController.java
@@ -99,7 +99,7 @@ public boolean upload(InputStream uploadedInputStream, FlowInfo flowInfo, String
    * @return
    */
   public boolean isUploaded(FlowInfo flowInfo, String hdfsPath) {
-    flowInfo.setFilePath(getTmpStagingDir(flowInfo.getFilename(), hdfsPath).toString());
+    flowInfo.setFilePath(getTmpStagingDir(hdfsPath, flowInfo.getFilename()).toString());
     return storage.isUploaded(flowInfo.hashCode(), flowInfo.getChunkNumber());
   }
 
@@ -217,7 +217,7 @@ private boolean hdfsStagingUpload(InputStream uploadedInputStream, FlowInfo flow
 
   private String getTmpStagingDir(DistributedFileSystemOps dfsOps, String filename, String hdfsPath)
     throws DatasetException {
-    Path userTmpDir = getTmpStagingDir(filename, hdfsPath);
+    Path userTmpDir = getTmpStagingDir(hdfsPath, filename);
     try {
       if (!dfsOps.exists(userTmpDir)) {
         boolean created = dfsOps.mkdirs(userTmpDir, dfsOps.getParentPermission(userTmpDir));