Can you help me with a similar issue? My code: import json import collections import java.io import ast   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 = ast.literal_eval(text)     mail = obj['mail']     outputStream.write(bytearray(json.dumps(obj['mail'], indent=4).encode('utf-8')))     outputStream.write(bytearray(json.dumps(obj['id'], indent=4).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')   flowFile = session.putAttribute(flowFile, "mail", mail) session.transfer(flowFile, REL_SUCCESS) session.commit()     I want to get "mail" value and create a new attribute for it. However, mail variable is not accessible when I insert it into the putattribute command. Any feedback? ... View more

@Kasun, as this is an older post, you would have a better chance of receiving a resolution by starting a new thread. This will also be an opportunity to provide details specific to your environment that could aid others in assisting you with a more accurate answer to your question. You can link this thread as a reference in your new post. ... View more

check this   https://community.cloudera.com/t5/Support-Questions/Apache-Nifi-username-password-for-Rest-Api/td-p/206404 ... View more

@balalaika ok, with no code changes here is the Structured version. Structured Streaming is basically just GA in Spark 2.2 which is HDP 2.6.4 and above. It works fine, a little different from the old style. They will probably keep the old one for until 2.5 or maybe 3.0. Both styles are nice. Another option is to use Apache Beam or Streaming Analytics Manager. https://community.hortonworks.com/content/kbentry/174105/hdp-264-hdf-31-apache-spark-structured-streaming-i.html ... View more

@balalaika For that case you need to specify Demarcator property as Shift+enter Configs:- For merge content reference https://community.hortonworks.com/questions/149047/nifi-how-to-handle-with-mergecontent-processor.html ... View more

Hi @Abdelkrim Hadjidj for now i will implement it with GetFTP, Nifi is in service provider network and i cannot upgrade at will 😞 Do you maybe know a way to tell GetFTP not to download files that have already been downloaded in the past to avoid unneccesary buffers? ... View more

@balalaika ^^ ... View more

Hi @Alexandru Anghel, ive uploaded a new question with my whole use case and logic here. Any help really appreciated! ... View more