[EAGLE-618] migration eagle-jpm-aggregation to application framework-bug fix
Author: wujinhu <wujinhu...@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 <wujinhu...@126.com> Authored: Fri Oct 14 17:46:33 2016 +0800 Committer: wujinhu <wujinhu...@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<>();