Repository: airavata Updated Branches: refs/heads/master 4286c8c85 -> 97b384b06
fixing error in monitorign. Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/97b384b0 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/97b384b0 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/97b384b0 Branch: refs/heads/master Commit: 97b384b0665579bf893e80703704788be6b8e9b7 Parents: 4286c8c Author: Ginnaliya Gamathige <[email protected]> Authored: Mon Nov 10 18:46:34 2014 -0500 Committer: Ginnaliya Gamathige <[email protected]> Committed: Mon Nov 10 18:46:34 2014 -0500 ---------------------------------------------------------------------- .../airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/97b384b0/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 9f93dc6..8e5f758 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 @@ -218,7 +218,7 @@ public class HPCPullMonitor extends PullMonitor { logger.info("AMQP message recieved: marking the Job as ************COMPLETE************ experiment {}, task {}, job name {} .", iMonitorID.getExperimentID(),iMonitorID.getTaskID(),iMonitorID.getJobName()); - monitorIDListIterator.remove(); + iterator.remove(); sendNotification(iMonitorID); GFacThreadPoolExecutor.getFixedThreadPool().submit(new OutHandlerWorker(gfac, iMonitorID, publisher)); break;
