Repository: airavata Updated Branches: refs/heads/master c2b9158ea -> 18f70920d
fixing a file transfer error Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/b810ee50 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/b810ee50 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/b810ee50 Branch: refs/heads/master Commit: b810ee505b1c5a50bf099f3f1dfddf98ff114ca1 Parents: 10139ba Author: lahiru <[email protected]> Authored: Fri Oct 3 12:34:05 2014 -0400 Committer: lahiru <[email protected]> Committed: Fri Oct 3 12:34:05 2014 -0400 ---------------------------------------------------------------------- .../airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/b810ee50/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java index 96edf3c..6b3ebc3 100644 --- a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java +++ b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java @@ -240,8 +240,9 @@ public class HPCPullMonitor extends PullMonitor { if (iMonitorID.getFailedCount() > FAILED_COUNT) { iMonitorID.setLastMonitored(new Timestamp((new Date()).getTime())); - JobDescriptor jobDescriptor = JobDescriptor.fromXML(iMonitorID.getJobExecutionContext().getJobDetails().getJobDescription()); - List<String> stdOut = connection.getCluster().listDirectory(jobDescriptor.getOutputDirectory()); // check the outputs directory + String outputDir = iMonitorID.getJobExecutionContext().getApplicationContext() + .getApplicationDeploymentDescription().getType().getOutputDataDirectory(); + List<String> stdOut = connection.getCluster().listDirectory(outputDir); // check the outputs directory if (stdOut.size() > 0) { // have to be careful with this completedJobs.put(iMonitorID.getJobName(), iMonitorID); logger.errorId(iMonitorID.getJobID(), "Job monitoring failed {} times, removed job {} from " +
