https://community.cloudera.com/t5/Support-Questions/Best-approach-to-re-merging-flowfiles-in-NiFi/m-p/214180#M176095 <P>It occurred to me that it might be better to just convert the entire flowfile contents to the stringify version rather than isolating the problematic blob first. I attempted this by using the following in the ExecuteScript:</P><PRE>var StreamCallback = Java.type("org.apache.nifi.processor.io.StreamCallback"); var IOUtils = Java.type("org.apache.commons.io.IOUtils"); var StandardCharsets = Java.type("java.nio.charset.StandardCharsets"); var flowFile = session.get(); if(flowFile != null) { // Create a new StreamCallback, passing in a function to define the interface method flowFile = session.write(flowFile, new StreamCallback(function(inputStream, outputStream) { var text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) outputStream.write(JSON.stringify(text).getBytes(StandardCharsets.UTF_8)) })); session.transfer(flowFile, REL_SUCCESS); } </PRE><P>However, the resulting content has been modified where the existing json structure is now masked by the use of escape characters before double quotes for instance. Is there an easy way to convert this object back into a json array? Thanks.</P> Fri, 28 Apr 2017 22:21:42 GMT murphy_sean 2017-04-28T22:21:42Z