Repository: airavata Updated Branches: refs/heads/master 881d169c6 -> 36158985c
removing retry in job submission Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/3c5fd4bb Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/3c5fd4bb Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/3c5fd4bb Branch: refs/heads/master Commit: 3c5fd4bb7024b9abf29e31ac3cba65707eb411fb Parents: a256f35 Author: lahiru <[email protected]> Authored: Thu Oct 2 23:12:43 2014 -0400 Committer: lahiru <[email protected]> Committed: Thu Oct 2 23:12:43 2014 -0400 ---------------------------------------------------------------------- .../gsi/ssh/impl/GSISSHAbstractCluster.java | 23 +++++--------------- 1 file changed, 5 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/3c5fd4bb/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java ---------------------------------------------------------------------- diff --git a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java index 4f13cf5..09d9b60 100644 --- a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java +++ b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/impl/GSISSHAbstractCluster.java @@ -297,25 +297,12 @@ public class GSISSHAbstractCluster implements Cluster { FileUtils.writeStringToFile(tempPBSFile, scriptContent); //reusing submitBatchJobWithScript method to submit a job - int retry = 3; String jobID = null; - while (retry > 0) { - try { - jobID = this.submitBatchJobWithScript(tempPBSFile.getAbsolutePath(), - jobDescriptor.getWorkingDirectory()); - retry = 0; - } catch (SSHApiException e) { - retry--; - try { - Thread.sleep(5000); - } catch (InterruptedException e1) { - e1.printStackTrace(); - } - reconnect(serverInfo, authenticationInfo); - if(retry==0) { - throw e; - } - } + try { + jobID = this.submitBatchJobWithScript(tempPBSFile.getAbsolutePath(), + jobDescriptor.getWorkingDirectory()); + } catch (SSHApiException e) { + throw e; } log.debug("Job has successfully submitted, JobID : " + jobID); if (jobID != null) {
