You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ha...@apache.org on 2016/10/24 14:47:47 UTC
incubator-eagle git commit: [MINOR] Fix hadoop jmx metric config
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 <ha...@apache.org>
Authored: Mon Oct 24 22:45:13 2016 +0800
Committer: Hao Chen <ha...@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