Repository: eagle Updated Branches: refs/heads/master 368197f62 -> 3fb7ff27d
[MINOR] Fix transform metric exception problem - Open transform function and use systemMetricDescriptor for sys metric. Author: r7raul1984 <[email protected]> Closes #891 from r7raul1984/minor-counttorate. Project: http://git-wip-us.apache.org/repos/asf/eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/3fb7ff27 Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/3fb7ff27 Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/3fb7ff27 Branch: refs/heads/master Commit: 3fb7ff27d4011a4a93e349df63099766486b37cb Parents: 368197f Author: r7raul1984 <[email protected]> Authored: Thu Mar 23 06:53:02 2017 +0000 Committer: r7raul1984 <[email protected]> Committed: Thu Mar 23 06:53:02 2017 +0000 ---------------------------------------------------------------------- .../apache/eagle/app/environment/builder/ApplicationBuilder.java | 1 - .../main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/eagle/blob/3fb7ff27/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/environment/builder/ApplicationBuilder.java ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/environment/builder/ApplicationBuilder.java b/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/environment/builder/ApplicationBuilder.java index 88f0886..05686f8 100644 --- a/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/environment/builder/ApplicationBuilder.java +++ b/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/environment/builder/ApplicationBuilder.java @@ -104,7 +104,6 @@ public class ApplicationBuilder { public class TransformedStream extends InitializedStream { public TransformedStream(String id) { super(id); - throw new IllegalStateException("TODO: Not implemented yet"); } } http://git-wip-us.apache.org/repos/asf/eagle/blob/3fb7ff27/eagle-metric/eagle-hadoop-metric/src/main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java ---------------------------------------------------------------------- diff --git a/eagle-metric/eagle-hadoop-metric/src/main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java b/eagle-metric/eagle-hadoop-metric/src/main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java index 9c0ac10..aa1753f 100644 --- a/eagle-metric/eagle-hadoop-metric/src/main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java +++ b/eagle-metric/eagle-hadoop-metric/src/main/java/org/apache/eagle/metric/HadoopMetricMonitorApp.java @@ -57,7 +57,7 @@ public class HadoopMetricMonitorApp extends StormApplication { return environment.newApp(config) .fromStream("HADOOP_JMX_METRIC_STREAM").transformBy(new CounterToRateFunction(hadoopMetricDescriptor,3, TimeUnit.SECONDS, ClockWithOffset.INSTANCE)) .saveAsMetric(hadoopMetricDescriptor) - .fromStream("SYSTEM_METRIC_STREAM").transformBy(new CounterToRateFunction(hadoopMetricDescriptor,3, TimeUnit.SECONDS, ClockWithOffset.INSTANCE)) + .fromStream("SYSTEM_METRIC_STREAM").transformBy(new CounterToRateFunction(systemMetricDescriptor,3, TimeUnit.SECONDS, ClockWithOffset.INSTANCE)) .saveAsMetric(systemMetricDescriptor ) .toTopology();
