eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject incubator-eagle git commit: [MINOR] Fix hadoop jmx metric config
Date Mon, 24 Oct 2016 14:47:47 GMT
Repository: incubator-eagle
Updated Branches:
  refs/heads/master 698b30282 -> 6b87fb3a7


[MINOR] Fix hadoop jmx metric config


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

Branch: refs/heads/master
Commit: 6b87fb3a714f6adf47ba4752b61284b638035f0e
Parents: 698b302
Author: Hao Chen <hao@apache.org>
Authored: Mon Oct 24 22:45:13 2016 +0800
Committer: Hao Chen <hao@apache.org>
Committed: Mon Oct 24 22:45:13 2016 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java  | 2 +-
 .../services/org.apache.eagle.app.spi.ApplicationProvider         | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/6b87fb3a/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java
b/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java
index d6d80f4..2207c8c 100644
--- a/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java
+++ b/eagle-core/eagle-app/eagle-app-base/src/main/java/org/apache/eagle/app/sink/KafkaStreamSink.java
@@ -109,7 +109,7 @@ public class KafkaStreamSink extends StormStreamSink<KafkaStreamSinkConfig>
{
             KafkaStreamSinkConfig desc = new KafkaStreamSinkConfig();
             String streamSpecificTopicConfigKey = getStreamSpecificTopicConfigKey(streamId);
             if (config.hasPath(streamSpecificTopicConfigKey)) {
-                desc.setTopicId(streamSpecificTopicConfigKey);
+                desc.setTopicId(config.getString(streamSpecificTopicConfigKey));
             } else if (config.hasPath(DEAULT_SHARED_TOPIC_CONF_KEY)) {
                 desc.setTopicId(config.getString(DEAULT_SHARED_TOPIC_CONF_KEY));
                 LOG.warn("Using default shared topic {}: {}", DEAULT_SHARED_TOPIC_CONF_KEY,
desc.getTopicId());

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/6b87fb3a/eagle-topology-assembly/src/resources/META-INF/services/org.apache.eagle.app.spi.ApplicationProvider
----------------------------------------------------------------------
diff --git a/eagle-topology-assembly/src/resources/META-INF/services/org.apache.eagle.app.spi.ApplicationProvider
b/eagle-topology-assembly/src/resources/META-INF/services/org.apache.eagle.app.spi.ApplicationProvider
index 4a3dc12..8b78e66 100644
--- a/eagle-topology-assembly/src/resources/META-INF/services/org.apache.eagle.app.spi.ApplicationProvider
+++ b/eagle-topology-assembly/src/resources/META-INF/services/org.apache.eagle.app.spi.ApplicationProvider
@@ -25,4 +25,5 @@ org.apache.eagle.jpm.mr.history.MRHistoryJobApplicationProvider
 org.apache.eagle.jpm.mr.running.MRRunningJobApplicationProvider
 org.apache.eagle.jpm.aggregation.AggregationApplicationProvider
 org.apache.eagle.hadoop.queue.HadoopQueueRunningAppProvider
-org.apache.eagle.topology.TopologyCheckAppProvider
\ No newline at end of file
+org.apache.eagle.topology.TopologyCheckAppProvider
+org.apache.eagle.metric.HadoopMetricMonitorAppProdiver
\ No newline at end of file


Mime
View raw message