@wengelbrecht thank you that is exactly what i needed to see.  I am having an issue with the parquet-hadoop-1.10 and need to get a 1.12 version working in NiFi and Hive....      ... View more

Hi all,   Above solution is failing at one scenario, Scenario: if multiple flow files processed at a time and  landed in the nifi queue which is used after update query ( i.e. puthiveql which increment processed_file_cnt by one for every flow file ) processor ,then there might be chances of triggering the next flow multiple times and that is wrong.   Because we do select processed_file_cnt first and then doing the comparison for processed_file_cnt with input_file_cnt.  ... View more

Thankyou Steven 🙂 ... View more

I’m the schema remove the second row in fields.  So it’s just id1.   Now do a test: use generateflowfile with the schema in contents.  Then evaluatejson.  In this processor click +, and make id1.  The value for id1 is then $.value.id1 (this is the code to get the real value.  Then route evaluatejson routes to an output port.  Run.  Inspect the item in the queue and confirm you see the attribute id1.   This is a simple example to help you understand how json works, how to get the data from the value object, how to confirm schema is correct, and how to unit test by looking at flowfile in the queue. ... View more

You should be able to accept your own reply as solution marking it closed/solved.   One thing I do notice, which I HIGHLY recommend against is using "localhost"...   ... View more

Thank you for your amazing advice and your support is highly appreciated. ... View more

Thanks Steven, I removed the hostname and it started working after I set hostname box empty. ... View more

Ahh I did not pay attention to that in the original screen shot, just tried to offer the syntax for the json parsing.   Glad you got it to work!   Isn't learning NiFi fun?  I love it. ... View more

Nice one!!  Always restart Ambari after any Ambari-server setup commands.   Very glad to see you got it! ... View more

In working with some advanced features (enable/disable compatibility) I was able to find the Swagger API link for my Schema Registry.  The link should look like:   http://hdf.cloudera.com:7788/swagger/#/   Simply add /swagger/ after your Schema UI port and it will take you there.   ... View more