[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