diff --git a/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java b/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java index bcb7a20..b2b74b4 100644 --- a/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java +++ b/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java @@ -594,13 +594,16 @@ public class QueueJobManager { AnalysisLogger.getLogger().info("Unnecessary to Uploading Files"); AnalysisLogger.getLogger().info("Loading files"); + //patch for concurrent uploads + String tempdir = ""+UUID.randomUUID()+"/"; for (File sfile : files) { if (sfile.getName().startsWith(".")) continue; String localf = sfile.getAbsolutePath(); String filename = sfile.getName(); - String remotef = remoteDir + sfile.getName(); + + String remotef = remoteDir + tempdir+sfile.getName(); if (uploadFiles) { client.put(true).LFile(localf).RFile(remotef); AnalysisLogger.getLogger().info("Uploading File "+localf+" as remote file "+remotef);