eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinh...@apache.org
Subject incubator-eagle git commit: [EAGLE-618] migration eagle-jpm-aggregation to application framework-bug fix
Date Fri, 14 Oct 2016 09:46:40 GMT
Repository: incubator-eagle
Updated Branches:
  refs/heads/master 98d1964ff -> 8ff8ecf1b


[EAGLE-618] migration eagle-jpm-aggregation to application framework-bug fix

Author: wujinhu <wujinhu920@126.com>

Closes #509 from wujinhu/EAGLE-618.


Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/8ff8ecf1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/8ff8ecf1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/8ff8ecf1

Branch: refs/heads/master
Commit: 8ff8ecf1b8d9ace5c87ad6acc30235b4a43d98bf
Parents: 98d1964
Author: wujinhu <wujinhu920@126.com>
Authored: Fri Oct 14 17:46:33 2016 +0800
Committer: wujinhu <wujinhu920@126.com>
Committed: Fri Oct 14 17:46:33 2016 +0800

----------------------------------------------------------------------
 .../org/apache/eagle/jpm/aggregation/AggregationApplication.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/8ff8ecf1/eagle-jpm/eagle-jpm-aggregation/src/main/java/org/apache/eagle/jpm/aggregation/AggregationApplication.java
----------------------------------------------------------------------
diff --git a/eagle-jpm/eagle-jpm-aggregation/src/main/java/org/apache/eagle/jpm/aggregation/AggregationApplication.java
b/eagle-jpm/eagle-jpm-aggregation/src/main/java/org/apache/eagle/jpm/aggregation/AggregationApplication.java
index b040d3e..214c688 100644
--- a/eagle-jpm/eagle-jpm-aggregation/src/main/java/org/apache/eagle/jpm/aggregation/AggregationApplication.java
+++ b/eagle-jpm/eagle-jpm-aggregation/src/main/java/org/apache/eagle/jpm/aggregation/AggregationApplication.java
@@ -35,13 +35,13 @@ public class AggregationApplication extends StormApplication {
         List<String> metricNames = new ArrayList<>();
         String[] metricNamesArr = config.getString("aggregate.counters.metrics").split(",");
         for (int i = 0; i < metricNamesArr.length; i++) {
-            metricNames.add(metricNamesArr[i]);
+            metricNames.add(metricNamesArr[i].trim());
         }
         List<String> groupByColumns = new ArrayList<>();
 
         String[] groupByColumnsArr = config.getString("aggregate.counters.groupBys").split(";");
         for (int i = 0; i < groupByColumnsArr.length; i++) {
-            groupByColumns.add(groupByColumnsArr[i]);
+            groupByColumns.add(groupByColumnsArr[i].trim());
         }
 
         Map<String, List<List<String>>> metrics = new HashMap<>();


Mime
View raw message