Repository: airavata Updated Branches: refs/heads/auroraMesosIntegration 6d51651ca -> bf5d8c796
Update aurora schedulear period to 5 sec Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/ba9d60d3 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/ba9d60d3 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/ba9d60d3 Branch: refs/heads/auroraMesosIntegration Commit: ba9d60d3e532987d4a25cdfb84e441271f7281d7 Parents: 6d51651 Author: Shameera Rathnayaka <[email protected]> Authored: Tue Nov 1 12:23:34 2016 -0400 Committer: Shameera Rathnayaka <[email protected]> Committed: Tue Nov 1 12:23:34 2016 -0400 ---------------------------------------------------------------------- .../org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/ba9d60d3/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java index 5fe9dd8..477f1db 100644 --- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java +++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/cloud/AuroraJobMonitor.java @@ -85,7 +85,7 @@ public class AuroraJobMonitor implements JobMonitor, Runnable { AuroraTimer task = null; try { task = new AuroraTimer(); - timer.schedule(task, 5000, 2000); + timer.schedule(task, 5000, 5000); } catch (Exception e) { log.error("Error couldn't run Aurora status poll timer task"); } @@ -96,7 +96,6 @@ public class AuroraJobMonitor implements JobMonitor, Runnable { jobMonitoringMap.put(jobId, taskContext); log.info("Added JobId : {} to Aurora Job Monitoring map", jobId); taskContext.getParentProcessContext().setPauseTaskExecution(true); - } @Override
