Re: HBase security label support

2017-06-29 Thread Bryan Bende
Mike, I don't know of any work being done or any JIRAs that exist for this, but seems like it would be good to support them. Most likely its just that no one has asked for it yet. I'd go ahead and create a JIRA, or if you were planning to incorporate it into the HBase record processors then that

HBase security label support

2017-06-29 Thread Mike Thomsen
Are there any plans for implementing HBase security labels? Thanks, Mike

Re: Need help in getMongo

2017-06-29 Thread Mike Thomsen
In fact, you probably don't even need one. Consider this contrived example: GetFile (load JSON) -> PutMongo (DB1) -> PutMongo (DB2) If you have data coming in that needs to go to two Mongo databases, the easiest way to handle it would be two PutMongos that act on the same flowfile,

Re: Need help in getMongo

2017-06-29 Thread Pierre Villard
Hi Kavitha, The query must be a JSON document, you have few examples in the test class GetMongoTest [1]. Regarding your second question, there is no incremental fetch feature for the Mongo processors at the moment. [1]

Re: Need help in getMongo

2017-06-29 Thread Mike Thomsen
1. Have you validated your query? I've been using GetMongo lately for a fairly large bulk ingestion job, and so far it's worked fine. 2. You can try something like this pattern: https://stackoverflow.com/questions/44573618/how-to-get-iso-string-in-nifi-getmongo-query-field/44725438#44725438 *

Need help in getMongo

2017-06-29 Thread Kavitha Alahari
Hello Team, I am trying to pull the data from MongoDB and try to put in other Mongo DB. For this I used GetMongo and PutMongo processors. Unfortunately none of the query is working in getMongo. However it is working when no query is there. Could you please provide me a sample query to use in

Re: NiFi and MapR streams?

2017-06-29 Thread Joey Frazee
Konstantin, this is a bit of a guess, but this might work with a NiFi that was built against MapR’s kafka-clients. So you’d need to change the kafka9.version property when building NiFi. For example: mvn clean install -DskipTests -Pmapr -Dhadoop.version=2.7.0-mapr-1703

NiFi and MapR streams?

2017-06-29 Thread KonstantinB
Hi guys, is there a way NiFi to consume MapR Streams? I try ConsumeKafka, which are using the 0.9 client - MapR Streams are compatible with Kafka 0.9, but it seems not working. Probably because MapR streams not used Zookeeper for stream detections, but а CLDB. Any help will be appreciated.

Re: Not able to start nifi nodes when clustered

2017-06-29 Thread Mark Payne
The problem that you're running into is that when NiFi starts, it tries to connect to ZooKeeper, but you have a two-node cluster, both running ZooKeeper. As a result, you will need both nodes up and running in order to establish a ZooKeeper quorum. So when you startup, you'll have trouble

Re: Not able to start nifi nodes when clustered

2017-06-29 Thread nifi-san
I was able to get over this.There was a typo and I can now start the two clustered Nifi nodes. However, I keep on getting the below messages on both the nodes when I try to start them. 2017-06-29 13:03:58,537 WARN [main] o.a.nifi.controller.StandardFlowService There is currently no Cluster