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 <swa...@hortonworks.com> Authored: Thu Jan 22 09:24:13 2015 -0800 Committer: Siddharth Wagle <swa...@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
