You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2014/03/11 17:34:54 UTC
git commit: more logs to monitoring - AIRAVATA-1023
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 <la...@apache.org>
Authored: Tue Mar 11 12:34:46 2014 -0400
Committer: lahiru <la...@apache.org>
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")) {