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/11/11 00:47:09 UTC
airavata git commit: fixing error in monitorign.
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 <lg...@BL-UITS-RTLT009.local>
Authored: Mon Nov 10 18:46:34 2014 -0500
Committer: Ginnaliya Gamathige <lg...@BL-UITS-RTLT009.local>
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;