Update MRRunningAppMetricBolt.java Author: yizt Reviewer: yonzhang Closes #969
Project: http://git-wip-us.apache.org/repos/asf/eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/dba01fbf Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/dba01fbf Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/dba01fbf Branch: refs/heads/master Commit: dba01fbf57f77c1d8773e24dc4a01ca5f238f5b6 Parents: f4370ac Author: yonzhang <[email protected]> Authored: Tue Apr 3 16:46:55 2018 -0700 Committer: yonzhang <[email protected]> Committed: Tue Apr 3 16:46:55 2018 -0700 ---------------------------------------------------------------------- .../apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/eagle/blob/dba01fbf/eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java ---------------------------------------------------------------------- diff --git a/eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java b/eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java index aa62d30..9cb2510 100644 --- a/eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java +++ b/eagle-jpm/eagle-jpm-mr-running/src/main/java/org/apache/eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java @@ -140,7 +140,7 @@ public class MRRunningAppMetricBolt extends BaseRichBolt { Map<String, String> tags = generateMetricTags(level, app); for (java.util.Map.Entry<String, String> entry : metrics.entrySet()) { Method method = AppInfo.class.getMethod(entry.getValue()); - Integer value = (Integer) method.invoke(app); + Integer value = Integer.valueOf(method.invoke(app).toString()); String metricName = String.format(entry.getKey(), level.name); createMetric(appMetricEntities, timestamp, tags, metricName, value); }
