From 1d62acf777f53b68bb9cadf5b8ba813f00d90b87 Mon Sep 17 00:00:00 2001
From: yizt <csuyzt@163.com>
Date: Fri, 13 Oct 2017 09:27:26 +0800
Subject: [PATCH] Update MRRunningAppMetricBolt.java
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修复java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer bug
---
 .../eagle/jpm/mr/running/storm/MRRunningAppMetricBolt.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 aa62d304fd..9cb2510c45 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 Map<String, GenericMetricEntity> parseRunningAppMetrics(List<AppInfo> run
                 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);
                 }