Thanks for the info @swagle. We were able to convince the customer to upgrade to Ambari 2.2.2. They were thrilled with the fact that you can add widgets directly in the UI, and the fact that Grafana is available is icing on the cake. Incidentally, here is the JIRA for adding this for Kafka and Storm: https://issues.apache.org/jira/browse/AMBARI-14941 ... View more

These files have stuff like this in them, so how do I get this info in Ambari? { "KAFKA_BROKER": { "Component": [ { "type": "ganglia", "metrics": { "default": { "metrics/jvm/uptime": { "metric": "jvm.uptime", "pointInTime": true, "temporal": true }, /* -- SNIP -- */ "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/count": { "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.count", "pointInTime": true, "temporal": true }, "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/1MinuteRate": { "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate", "pointInTime": true, "temporal": true }, "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/5MinuteRate": { "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.5MinuteRate", "pointInTime": true, "temporal": true }, "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/15MinuteRate": { "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.15MinuteRate", "pointInTime": true, "temporal": true }, "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/meanRate": { "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.meanRate", "pointInTime": true, "temporal": true }, "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/count": { "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.count", "pointInTime": true, "temporal": true }, "metrics/kafka/controller/KafkaController/ActiveControllerCount": { "metric": "kafka.controller.KafkaController.ActiveControllerCount", "pointInTime": true, "temporal": true }, ... View more

If your index is of any significant size or has much of a load on it, I would recommend you install it on separate nodes. ... View more

I had something like this happen on my 16G macbook pro when I switched from 0.4.1 to 0.6.0 and reused the repository directories. It was just an experimental instance, so I abandoned the original repos and started from scratch, except for importing a few flows. I have not had the problem since. The odd thing in my case is that it was fine in 0.4.1 but not in 0.6.0. ... View more

I wanted to offer another comparison tool option. After downloading configs, you might consider using a graphical tool like meld. It does a very nice job of file and directory comparison and merges. It will not only point out line differences but highlight character differences. Check out the images on their home page to know what to expect: http://http://meldmerge.org If you're doing a shell comparison using diff, try the -y option for a side-by-side diff. And there is a recursive option -r to compare directories. diff -ry <dirA> <dirB> ... View more

Awesome! Thanks for the full sample. By digging through source code I figured out that I could use the property object with evaluateExpressions(flowFile), but I did not realize that testProperty is a property already. duh. This is what I had tried but it printed "null", so assumed I was going down the wrong path. flowFile = session.get() if(!flowFile) return def retVal = context.getProperty('testProperty').evaluateExpressions(flowFile) log.info("-----------------------"+retVal?.value) session.transfer(flowFile, REL_SUCCESS) ... View more