We have a nifi two node cluster on vm ,and need to process the data to cosmosDb graph api from azure sql server,i have written a custom processors to get the data from sql server and import into graph api, I have 6 connection stirngs for each user that means 6 flowfiles : Flow like:first populate the users,items,and items they have bought into graphDb ,like this ,everything is fine fetching data but problem is while inserting into graph db ,each flowfile size 12mb to 30 mb data . even we have 2 node cluster ,but processing the data only in one node not processing by both ,so its taking time and hanging and getting heap out of memory exception ,not able to insert all users data Could you plz explain the cluster how to configure two process the data by two nodes . ... View more

drawing-1.jpegHi, I have a requirement to to wait one processor upto another processor complets its task 1.Let say I have a json array ,which contains the 6 json objects, i am splitting the json array so then i have 6 flowfiles 2.These 6 flowfiles one by one sending to the invokeHttp processor and get the 6 responses .Here i need to check the last response if its success then i need to start the another processor 3.I have attached the diagram representation ,please find. In Nifiprocessor box which one i should use.Could you please provide the solution ? Thanks ... View more