I'm not seeing the load balancing being set on the success relationship of the DuplicateFlowFile. That will basically mean that the PutFile processor will be executed on each node (as many as the flowfile coming out of the duplicate processor. ... View more

Have you set the load balancing strategy on the queue upstream the put file to round robin. If that doesnt work for some reason, then your only option is to create a shared folder on all nodes, then you will have a workflow that picks up the file then you add as many PUTFile processors as the number of your nodes where each put file will save the file to a given node shared folder. ... View more

Hi, If you want to check for number match in the routeOnAttribute. You can create dynamic property called for example "filenameHasNumeric" and set the value to the following expression "${filename:matches('.*\d+.*')}". You can set the routing strategy to  "Route to 'matched' if all matches" to get "matched" or "unmatched" relationships. If that solves the problem please accept it as solution. Thanks ... View more

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