You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sw...@apache.org on 2015/01/22 18:24:23 UTC
ambari git commit: AMBARI-9185. Add Kafka metric sink implementation
to enable sink to AMS. Debian packaging changes.
Repository: ambari
Updated Branches:
refs/heads/trunk 0edce3c4f -> ac240927a
AMBARI-9185. Add Kafka metric sink implementation to enable sink to AMS. Debian packaging changes.
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/ac240927
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/ac240927
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/ac240927
Branch: refs/heads/trunk
Commit: ac240927ab0d836f0fd57df4589787b5799ce03c
Parents: 0edce3c
Author: Siddharth Wagle <sw...@hortonworks.com>
Authored: Thu Jan 22 09:24:13 2015 -0800
Committer: Siddharth Wagle <sw...@hortonworks.com>
Committed: Thu Jan 22 09:24:18 2015 -0800
----------------------------------------------------------------------
ambari-metrics/ambari-metrics-assembly/pom.xml | 1 +
.../src/main/package/deb/control/postinst | 11 ++++++++---
2 files changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/ac240927/ambari-metrics/ambari-metrics-assembly/pom.xml
----------------------------------------------------------------------
diff --git a/ambari-metrics/ambari-metrics-assembly/pom.xml b/ambari-metrics/ambari-metrics-assembly/pom.xml
index 8614421..6236187 100644
--- a/ambari-metrics/ambari-metrics-assembly/pom.xml
+++ b/ambari-metrics/ambari-metrics-assembly/pom.xml
@@ -614,6 +614,7 @@
<path>/var/lib/ambari-metrics-collector</path>
<path>/usr/lib/ambari-metrics-hadoop-sink</path>
<path>/usr/lib/ambari-metrics-kafka-sink</path>
+ <path>/usr/lib/ambari-metrics-kafka-sink/lib</path>
<path>/usr/lib/flume/lib</path>
<path>/usr/lib/storm/lib</path>
</paths>
http://git-wip-us.apache.org/repos/asf/ambari/blob/ac240927/ambari-metrics/ambari-metrics-assembly/src/main/package/deb/control/postinst
----------------------------------------------------------------------
diff --git a/ambari-metrics/ambari-metrics-assembly/src/main/package/deb/control/postinst b/ambari-metrics/ambari-metrics-assembly/src/main/package/deb/control/postinst
index 1955680..e87b9f0 100644
--- a/ambari-metrics/ambari-metrics-assembly/src/main/package/deb/control/postinst
+++ b/ambari-metrics/ambari-metrics-assembly/src/main/package/deb/control/postinst
@@ -15,15 +15,20 @@
# limitations under the License
HADOOP_LINK_NAME="/usr/lib/ambari-metrics-hadoop-sink/ambari-metrics-hadoop-sink.jar"
-FLUME_LINK_NAME="/usr/lib/flume/lib/ambari-metrics-flume-sink.jar"
HADOOP_SINK_JAR="/usr/lib/ambari-metrics-hadoop-sink/${hadoop.sink.jar}"
+
+FLUME_LINK_NAME="/usr/lib/flume/lib/ambari-metrics-flume-sink.jar"
FLUME_SINK_JAR="/usr/lib/flume/lib/${flume.sink.jar}"
+
+KAFKA_LINK_NAME="/usr/lib/ambari-metrics-kafka-sink/ambari-metrics-kafka-sink.jar"
+KAFKA_SINK_JAR="/usr/lib/ambari-metrics-kafka-sink/${kafka.sink.jar}"
+
#link for storm jar not required with current loading
#STORM_SINK_JAR="/usr/lib/storm/lib/${storm.sink.jar}"
#STORM_LINK_NAME="/usr/lib/storm/lib/ambari-metrics-storm-sink.jar"
-JARS=(${HADOOP_SINK_JAR} ${FLUME_SINK_JAR})
-LINKS=(${HADOOP_LINK_NAME} ${FLUME_LINK_NAME})
+JARS=(${HADOOP_SINK_JAR} ${FLUME_SINK_JAR} ${KAFKA_SINK_JAR})
+LINKS=(${HADOOP_LINK_NAME} ${FLUME_LINK_NAME} ${KAFKA_LINK_NAME})
for index in ${!LINKS[*]}
do