Hi, The string you are getting is not a valid json, so you need to use ExecuteScript Processor to parse the string and convert into array and then convert the array into json array. You can convert this string into array by removing curly brackets and then do split(',') then you can convert the array into json using something like: https://www.javaguides.net/2019/07/convert-set-to-json-array-using-jackson.html Pass the converted Json Array as new flowfile from the ExecuteScript Processor. Lets assume that your json array looks like this:   ["1","1","1","3465689","B4:E6:2D:34:E1:D9"...]   Then you use Json Jolt Processor and pass the following Jolt Spec:   [  {    "operation": "shift",       "spec": {              "*": {                    "@0": "Value-&0"                  }               }        } ]   which will give the new flowfile as follows:   { "Value-0" : "1", "Value-1" : "1", "Value-2" : "1", "Value-3" : "3465689", "Value-4" : "B4:E6:2D:34:E1:D9" ... }   Hope that helps. If it does please accept solution. Thanks Samer ... View more

Hi, Which system did you install Nifi on ? If windows try to click any Java job running in the background and restart nifi. ... View more

By the way what is inside the users.xml file? ... View more

Sure, I hope they can help. By the have you seen my comments above about defining the nodes in the auotherizers.xml with the following format (case sensitive):   CN=masternode, OU=NIFI CN=workernode02, OU=NIFI CN=workernode03, OU=NIFI   ... View more

Just to be on the safe side, can you define the nodes in the authorizers.xml as follows. Keep in mind when you define something in the nifi config files its is case sensitive.   CN=masternode, OU=NIFI CN=workernode02, OU=NIFI CN=workernode03, OU=NIFI ... View more

@MattWho, @araujo , can you guys help? ... View more

Its hard to tell what is causing the error , the only thing for me is just verifying that you followed the steps accordingly to setup the cluster. One thing you did not mentioned is creating the myid file under the folder ./state/zookeeper on each node that defines the node number as mentioned in the url I provided before, did you do that? ... View more

What the screenshot is telling that its still initializing the data flow, so give it some time and refresh. ... View more

Sorry I forgot to mention that in the PutSql processor set the Batch Size property to 1 ... View more

Have you added the nodes in the authorizers.xml under userGroupProvider and AccessPolicyProvider ... View more

Im not familiar with the postgress sql but should not be like this: INSERT INTO table(column1, column2, …) VALUES (value1, value2, …);   Also for the value you need to provide the attribute name , so it should be something like this: INSERT INTO table(jsonDataColumn) VALUES(${data});   ... View more

Not sure if this is related , but if you are setting up a secure cluster the property nifi.cluster.protocol.is.secure should be true. If not just make sure you follow steps mentioned in the following url and you have not missed anything: https://nifi.apache.org/docs/nifi-docs/html/walkthroughs.html#creating-and-securing-a-nifi-cluster-with-the-tls-toolkit ... View more

Hi,   Can you explain what happen when you use the PutDatabaseRecrod Processor? ... View more

how is the original flowfile is generated. usually you should have filename  attribute set by default on the original flowfile. this should be unique for the flowfile and this filename could be passed to the output stream, can you check that? ... View more

Is there a  unique attribute on the original flowfile (like filename) that gets set on the output stream ? if so, you can set the mergeContent processor  property " Correlation Attribute Name " to the attribute containing the unique value that is shared between original and output, this way you guarantee that only related original and output are getting merged. ... View more

Hi, Not sure I fully understand your question. Can you please provide screenshot of the flow you have and explain the expected output of each processor? From what I can understand you want to keep the original file but somehow you want to attach the output of the command stream to it. There is property on the ExecuteCommandStream Processor called " Output Destination Attribute " where you can store the output stream as an attribute on the original flow file. if you want to modify the content of the flow file after that based on the new attribute then you can use ExecuteScript Processor.   ... View more

Hi, regarding the first point I dont think you can do that through regex, this is more of transformation operation and you might need to use JsonJolt Processor to do transromation first to simplify the json and store all id's in an array then use regular expression to extract the ids. It will complicate matter it might affect performance. What kind of SQL are you using ? Do you have any json functions in that sql? If that is the case I would recommend you deffer this process to SQL and utilize sql function to parse json.  For example in MS SQL you can use OPENJSON function to transpose json into table and then you can use this table in your query. For the second point, this is because the way the extractText reg expression work it treats like group, so beside the main attribute you will get an indexed attribute for each matched group. You can read more about this here: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.5.0/org.apache.nifi.processors.standard.ExtractText/index.html   You can also use this post to see if you can extract one attirbute. I just found about it: https://community.cloudera.com/t5/Support-Questions/Extract-whole-json-flowfilecontent-small-to-single-attribute/m-p/308960   ... View more