From f9c1eff739cadd88d6f25c54eac3d4b1b1602588 Mon Sep 17 00:00:00 2001 From: Gianpaolo Coro Date: Thu, 14 May 2015 21:39:33 +0000 Subject: [PATCH] patch for concurrent uploads git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@114756 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../executor/job/management/QueueJobManager.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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);