eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjt...@apache.org
Subject eagle git commit: [MINOR] Fix transform metric exception problem
Date Thu, 23 Mar 2017 06:53:47 GMT
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 <tangjijun@yhd.com>

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 <tangjijun@yhd.com>
Authored: Thu Mar 23 06:53:02 2017 +0000
Committer: r7raul1984 <tangjijun@yhd.com>
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();


Mime
View raw message