gCubeSystem
/
ecological-engine-smart-executor
15
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

session management 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@122707 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Gianpaolo Coro 2016-02-01 22:09:10 +00:00
parent ff84a0f9d3
commit 94191c542f
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/gcube/dataanalysis/executor/job/management/DistributedProcessingAgent.java
View File

@ -36,6 +36,7 @@ public class DistributedProcessingAgent {
protected int leftSetNumberOfElements; protected int leftSetNumberOfElements;
protected List<String> endpoints; protected List<String> endpoints;
protected int subdivisiondiv; protected int subdivisiondiv;
protected String sessionID;
protected static String defaultJobOutput = "execution.output"; protected static String defaultJobOutput = "execution.output";
protected static String defaultScriptFile = "script"; protected static String defaultScriptFile = "script";
@ -57,7 +58,8 @@ public class DistributedProcessingAgent {
int maxElementsPerJob, int maxElementsPerJob,
boolean forceReUploadofLibs, boolean forceReUploadofLibs,
int leftSetNumberOfElements, int leftSetNumberOfElements,
int rightSetNumberOfElements int rightSetNumberOfElements,
String sessionID
) { ) {
this.stop = false; this.stop = false;
this.deletefiles = true; this.deletefiles = true;
@ -72,6 +74,7 @@ public class DistributedProcessingAgent {
this.pathToLib=pathToLibFolder; this.pathToLib=pathToLibFolder;
this.modelName=modelName; this.modelName=modelName;
this.containerFolder=containerFolder; this.containerFolder=containerFolder;
this.sessionID = sessionID;
} }
public void setLogger(Logger logger){ public void setLogger(Logger logger){
@ -104,9 +107,9 @@ public class DistributedProcessingAgent {
jobManager = new QueueJobManager(gscope, endpoints.size(), eprtList); jobManager = new QueueJobManager(gscope, endpoints.size(), eprtList);
*/ */
jobManager = new QueueJobManager(gscope, endpoints.size(), endpoints); jobManager = new QueueJobManager(gscope, endpoints.size(), endpoints,sessionID);
} else } else
jobManager = new QueueJobManager(gscope, 1); jobManager = new QueueJobManager(gscope, 1,sessionID);
int numberOfResources = jobManager.getNumberOfNodes(); int numberOfResources = jobManager.getNumberOfNodes();
// we split along right dimension so if elements are less than nodes, we should reduce the number of nodes // we split along right dimension so if elements are less than nodes, we should reduce the number of nodes