Have you changed anything in the authorizers file after setting it up the first time. If so try deleting "users.xml" and "authorizations.xml" files and restart nifi. Those files will be re created based on the latest setup in the authorizers.xml ... View more

Can you try the following Json and see if you get any duplicates: [ { "sport": "Soccer", "name": "John Smith" }, { "sport": "Soccer", "name": "John Smith" }, { "sport": "tennis", "name": "John Smith" }, { "sport": "tennis", "name": "John Smith" }, { "sport": "tennis", "name": "John Smith" } ] Basically Create GenerateFlowFile processor and add the json above as the CustomText. Then Add CalculateRecordStats and provide the JsonTreeReader in the RecrodReader. Run and see if you get any duplicates. If so then I would recommend you upgrade to later version. ... View more

Hi,   Which version of Nifi are you using? Can you share sample of the csv content and what you do in the update attribute to see if I can replicate it? Im using nifi 1.16 and when a try it ont he sample provided by the CalculateRecordStats help (under additional information) I dont get any duplicates. ... View more

how do you log in to the site? do you use the same user that the certificate is created against which should be as specified in the "Initial admin property" in the authorizers.xml file? ... View more

If you are looking to authenticate using Oath2.0 then you need to create new property in the InvokeHttp processor and call the property "Authorization" and the value should be set as: "Bearer [Authorization Token]". First you need to get the authentication token. hope that helps. ... View more

Hi, There is a processor called DuplicateFlowFile where you configure it with the Number of Copies that you wish to have. I assume in your case if you want to process it on multiple nodes then the number of copies should be n-1 (where n is number of nodes and -1 because you still have the original flow file). In the downstream queue for this processor success relationship make sure to configure the queue Load Balance Strategy to "Round Robin" where each flowfile will be send to a different node. Hope that helps. ... View more

It worked for me. I have tried it before posting it and got the expected result. make sure the old code that was throwing the error is not there ... View more

Try this: end_next_year = datetime.strptime(current_date,'%Y-%m-%d').replace(year = datetime.strptime(current_date,'%Y-%m-%d').year+1).strftime('%Y%m%d') ... View more

set the date filter as follows: date_filter = datetime.strptime(current_date,'%Y-%m-%d').replace(day =11).strftime('%Y%m%d')   If that solves your problem please accept solution. Thanks ... View more