[rhq] Branch 'feature/hadoop-plugin' - modules/plugins

lkrejci lkrejci at fedoraproject.org
Mon Aug 6 16:09:04 UTC 2012


 modules/plugins/hadoop/src/main/java/org/rhq/plugins/hadoop/JobTrackerServerComponent.java |    1 +
 1 file changed, 1 insertion(+)

New commits:
commit 1308865d4e3c080a436e80205ca1caf44e11bb0d
Author: Lukas Krejci <lkrejci at redhat.com>
Date:   Mon Aug 6 18:08:40 2012 +0200

    Clear out the pending calltime metrics after reporting them.

diff --git a/modules/plugins/hadoop/src/main/java/org/rhq/plugins/hadoop/JobTrackerServerComponent.java b/modules/plugins/hadoop/src/main/java/org/rhq/plugins/hadoop/JobTrackerServerComponent.java
index 539f8f6..8368cbf 100644
--- a/modules/plugins/hadoop/src/main/java/org/rhq/plugins/hadoop/JobTrackerServerComponent.java
+++ b/modules/plugins/hadoop/src/main/java/org/rhq/plugins/hadoop/JobTrackerServerComponent.java
@@ -83,6 +83,7 @@ public class JobTrackerServerComponent extends HadoopServerComponent {
                 updateUnprocessedMeasurements();
                 Map<String, Set<JobSummary>> pendingJobs = unprocessedCalltimeMeasurements.get(request.getName());
                 report.addData(createCalltimeData(request, pendingJobs));
+                pendingJobs.clear();
             }
         } else {
             super.handleMetric(report, request);




More information about the rhq-commits mailing list