From 256d503c29f358cf73d5881c7bd7906585be50ab Mon Sep 17 00:00:00 2001 From: ErmiasG Date: Tue, 16 Jan 2024 18:19:45 +0100 Subject: [PATCH] [HWORKS-912] 3.5 append (#1455) --- .../io/hops/hopsworks/common/upload/UploadController.java | 4 ++-- 1 file changed, 2 insertions(+), 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 index d8a2b36613..9d8d8cb7e9 100644 --- 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));