Hello,   could you please check right before UpdateAttribute Processor, if the attribute "name" is filled with your expected content? Normally it is correct what you explain - maybe you loose somewhere after merge, wait/notify, ... your attribute.   Greetings ... View more

Hello @Techie123, can you tell a bit more about what you want to achive?   Do you want just use the first or second object of 'data'? Then you have to change: "data": { "0": { "data": { "1": {  Or how do you want to progress - can it that the numbers are not similiar? We dont know how your results can be look like   Greetings ... View more

Hello @Manimaran, to help you it would be good if you go a bit more specific into your question with some sample content and what you want to have as expected output.   Greetings ... View more

@Techie123 maybe you can beautify it a bit 😄   import org.apache.commons.io.IOUtils import java.nio.charset.StandardCharsets import groovy.json.* import java.util.ArrayList def flowFile = session.get() if (!flowFile) return try { flowFile = session.write(flowFile, { inputStream, outputStream -> def text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) def content = new JsonSlurper().parseText(text) for (int i = content.size() - 1; i >= 0; --i) { int objNo = i int recNo = i + 1 def rec = 'Record ' + recNo if (rec != content[objNo].enrichment.Record) { content.remove(content[objNo]) } } def jsonOutput = JsonOutput.toJson(content) outputStream.write(JsonOutput.prettyPrint(jsonOutput).getBytes(StandardCharsets.UTF_8)) } as StreamCallback) session.transfer(flowFile, REL_SUCCESS) } catch (Exception e) { log.error('Error during JSON operations', e) session.transfer(flowFile, REL_FAILURE) }   ... View more

Hello @Techie123     I added a operation to your  Jolt Specification , try it with:   [ { "operation": "shift", "spec": { "data": { "*": { "Id": "[&1].Id", "Date": "[&1].Date", "$": "[&1].array_Ind" } } } }, { "operation": "modify-overwrite-beta", "spec": { "*": { "array_Ind": "=intSum(1,@(1,array_Ind))" } } }, { "operation": "modify-default-beta", "spec": { "*": { "Record": "=concat('Record ',@(1,array_Ind))" } } } ] Greetings ... View more