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

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

1 use ReplaceText Processor just before ExecuteSparkInteractive and paste your code in ReplaceText Processor and you can access attributes in replace text processor using nifi expression like ${attributename}. 2 In ExecuteSparkInteractive ,keep code peoperty as empty because  This property can be empty, a constant value, or built from attributes using Expression Language. If this property is specified, it will be used regardless of the content of incoming flowfiles. If this property is empty, the content of the incoming flow file is expected to contain valid code to be issued by the processor to the session.Note that Expression Language is not evaluated for flow file contents. Hope This will work.   ... View more