Hi We are experiencing trouble in flowFile = session.write(flowFile, ModJSON()) that line. javax.script.ScriptException: TypeError: write(): 1st arg can't be coerced to int , byte[] in <script> at line number 64 Do you think what is the problem: import json import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback class ModJSON(StreamCallback): def __init__(self): pass def process(self, inputStream, outputStream): text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) obj = json.loads(text) endorsements = obj['endorsement'].split(',') categoryIds = obj['categoryIds'].split(',') orderItemIds = obj['orderItemIds'].split(',') seq_num = 0 seq_num1 = 1 for endorsement in endorsements: if seq_num == 0 and seq_num1 == len(endorsements): newObj = '[{"endorsement":' + endorsement \ + ',"eventId":"' + obj['eventId'] \ + '", "categoryId":"' + categoryIds[seq_num] \ + '", "createDate":"' + obj['createDate'] \ + '", "buyerId":"' + obj['buyerId'] \ + '", "channel":"' + obj['channel'] + '", "city":"' \ + obj['city'] + '", "orderItemId": "'+orderItemIds[seq_num]+'"}]' seq_num += 1 seq_num1 += 1 elif seq_num == 0: newObj = '[{"endorsement":' + endorsement + ',"eventId":"' \ + obj['eventId'] + '", "categoryId":"' \ + categoryIds[seq_num] + '", "createDate":"' \ + obj['createDate'] + '", "buyerId":"' \ + obj['buyerId'] + '", "channel":"' + obj['channel' ] + '", "city":"' + obj['city'] + '", "orderItemId": "'+orderItemIds[seq_num]+'"},' seq_num += 1 seq_num1 += 1 elif seq_num1 == len(endorsements) : newObj += '{"endorsement":' + endorsement + ',"eventId":"' \ + obj['eventId'] + '", "categoryId":"' \ + categoryIds[seq_num] + '", "createDate":"' \ + obj['createDate'] + '", "buyerId":"' \ + obj['buyerId'] + '", "channel":"' + obj['channel' ] + '", "city":"' + obj['city'] + '", "orderItemId": "'+orderItemIds[seq_num]+'"}]' seq_num += 1 seq_num1 += 1 else: newObj += '{"endorsement":' + endorsement + ',"eventId":"' \ + obj['eventId'] + '", "categoryId":"' \ + categoryIds[seq_num] + '", "createDate":"' \ + obj['createDate'] + '", "buyerId":"' \ + obj['buyerId'] + '", "channel":"' + obj['channel' ] + '", "city":"' + obj['city'] + '", "orderItemId": "'+orderItemIds[seq_num]+'"},' seq_num += 1 seq_num1 += 1 outputStream.write(bytearray(newObj.encode('utf-8'))) flowFile = session.get() if flowFile != None: flowFile = session.write(flowFile, ModJSON()) flowFile = session.putAttribute(flowFile, 'filename', flowFile.getAttribute('filename' ).split('.')[0] + '_translated.json' ) session.transfer(flowFile, REL_SUCCESS) session.commit() ... View more