You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by yo...@apache.org on 2018/04/04 00:09:54 UTC
[2/2] eagle git commit: Update MRRunningAppMetricBolt.java Author:
yizt Reviewer: yonzhang
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 <yo...@ebay.com>
Authored: Tue Apr 3 16:46:55 2018 -0700
Committer: yonzhang <yo...@ebay.com>
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);
}