You can try this ${message:unescapeXml()} This function unescapes a string containing XML entity escapes to a string containing the actual Unicode characters corresponding to the escapes.     ... View more

Thanks @suraj143  I ended up using an UpdateRecord, but your approach with a JoltTransformJSON also works. ... View more

In Nifi, There is a bootstrap.conf file inside the conf folder.  You can update the value of the following properties, # JVM memory settings java.arg.2=-Xms2g  java.arg.3=-Xmx8g https://community.cloudera.com/t5/Community-Articles/How-to-address-JVM-OutOfMemory-errors-in-NiFi/ta-p/244431  ... View more

jolt specification : [{ "operation": "shift", "spec": { "@": "&", "data": { "*": { "id": { "@(1)": "idexist.[]" }}}}}] output :  { "root" : { "data" : [ { "name" : "a", "id" : "100" }, { "name" : "b", "id" : "101" }, { "name" : "c" } ] }, "idexist" : [ { "name" : "a", "id" : "100" }, { "name" : "b", "id" : "101" } ] } ... View more