Update: Created a custom processor by duplicating PutDatabaseRecord and added the if statement that was done in the commit https://github.com/apache/nifi/pull/4772/commits/0d6bca493842286ddae6a0577dfed55cd1808f7c. It solved the issue but I had to create a NAR with all of the bundled dependencies in nifi-standard-processors because I was having an error while starting NiFi (https://community.cloudera.com/t5/Support-Questions/Nifi-throwing-error-on-startup/m-p/240893) I've checked the code base and the if statement is not present in Nifi > 1.12   Hey @MattWho, since you were the only one helping and @mburgess is not replying to the ticket, do you think it is possible/doable to create an hot-fix or something like that to have this commit? - I've seen more people complaining regarding this issue and it would be useful to not duplicate the source code just to add an if statement   Thanks   ... View more

Hey @mburgess could you give a little help in this ticket? I am still facing this issue and I'm not sure how to implement a workaroud ... View more

Hey, I can be missing something, but what are you trying to accomplish with this? Having more than one NiFi node? Having more than one ZK node? Also, what are you using for the setup? Docker? ... View more

Hey, Generally JOLT tries to maintain the input order. The only way that I can think about is an hard-coded approach. Add this after the default spec: { "operation": "shift", "spec": { "Order": { "*": { "top-level": { "ProcessType": "[&2].ProcessType", "FreightTerm": "[&2].FreightTerm", "OrderNumber2": "[&2].OrderNumber2", "TransmissionCommand": "[&2].TransmissionCommand", "SequenceNumber": "[&2].SequenceNumber", "SenderAbbreviation": "[&2].SenderAbbreviation" }, "CustomerAddress": "[&1].CustomerAddress", "ShipmentAddress": "[&1].ShipmentAdress", "Volume": "[&1].Volume", "Weight": "[&1].Weight" } } } }   Also, are you trying to "duplicate" the value of "OrderNumber2"?   The other solution I can remember to "replace" JOLT is by using FasterXML/Jackson ... View more