Repository: airavata Updated Branches: refs/heads/master 4d254f1f3 -> f7dba4ecb
more logs to monitoring - AIRAVATA-1023 Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/f7dba4ec Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/f7dba4ec Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/f7dba4ec Branch: refs/heads/master Commit: f7dba4ecb54d62ab13437068ff4d471c8b40ff20 Parents: 4d254f1 Author: lahiru <[email protected]> Authored: Tue Mar 11 12:34:46 2014 -0400 Committer: lahiru <[email protected]> Committed: Tue Mar 11 12:34:46 2014 -0400 ---------------------------------------------------------------------- .../apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java | 2 +- .../org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/f7dba4ec/modules/airavata-job-monitor/src/main/java/org/apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java ---------------------------------------------------------------------- diff --git a/modules/airavata-job-monitor/src/main/java/org/apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java b/modules/airavata-job-monitor/src/main/java/org/apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java index d5bfed2..f2ed33d 100644 --- a/modules/airavata-job-monitor/src/main/java/org/apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java +++ b/modules/airavata-job-monitor/src/main/java/org/apache/airavata/job/monitor/impl/pull/qstat/QstatMonitor.java @@ -74,7 +74,7 @@ public class QstatMonitor extends PullMonitor { try { startPulling(); // After finishing one iteration of the full queue this thread sleeps 1 second - Thread.sleep(5000); + Thread.sleep(30000); } catch (Exception e){ // we catch all the exceptions here because no matter what happens we do not stop running this // thread, but ideally we should report proper error messages, but this is handled in startPulling http://git-wip-us.apache.org/repos/asf/airavata/blob/f7dba4ec/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java ---------------------------------------------------------------------- diff --git a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java index 5aeee94..4fffc32 100644 --- a/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java +++ b/tools/gsissh/src/main/java/org/apache/airavata/gsi/ssh/api/job/SlurmOutputParser.java @@ -30,7 +30,7 @@ import java.util.Map; public class SlurmOutputParser implements OutputParser { private static final Logger log = LoggerFactory.getLogger(PBSOutputParser.class); public void parse(JobDescriptor descriptor, String rawOutput) { - log.debug(rawOutput); + log.info(rawOutput); String[] info = rawOutput.split("\n"); String lastString = info[info.length -1]; if (lastString.contains("JOB ID")) { @@ -90,6 +90,7 @@ public class SlurmOutputParser implements OutputParser { * @return */ public String parse(String rawOutput) { + log.info(rawOutput); String[] info = rawOutput.split("\n"); for (String anInfo : info) { if (anInfo.contains("Submitted batch job")) {
