Hi Team, I am trying to implement for the scenario where the events should sleep for 5 minutes and let all the flow files are queued up, then check the count of the files if it is greater than 10 route to failure else route to SUCCESS. I did in Execute script processor as below. However, i am trying to avoid the executescript for this and try to use Native nifi processors. ====== Executescript =============== Thread.sleep(300000) def flowFiles = session.get(100) if (!flowFiles || flowFiles.size() <= 10) { session.transfer(flowFiles, REL_SUCCESS) } else { session.transfer(flowFiles, REL_FAILURE) }     ... View more

Hi All,   I would like to capture the Nifi processor error message due to failure on some reasons. The popup coming up and getting expired in 5 minutes.My plan is  the error messages should be captured (like by some Nifi processors) and send it via email.I cannot capture the error messages on the fly. Any thoughts on this please?.     Ex: The screenshot has the error message and and i need to capture the entire messages and send via email. ... View more

HI All, I am trying to iterate the nifi flow file and modify each line in the flow file using python script in 'ExecuteScript'.But it is not working as expected. For example i would like to append 'Rajiv' string at the end for each line in the flow file.but it is adding only at the end of the end of the flow file. Code Execute script content: 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 PyStreamCallback(StreamCallback): def __init__(self, flowfile): self.ff = flowfile pass def process(self, inputStream, outputStream): text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) text = text + 'rajiv' outputStream.write(bytearray(text.encode('utf-8'))) flowFile = session.get() if (flowFile != None): flowFile = session.write(flowFile,PyStreamCallback(flowFile)) session.transfer(flowFile, REL_SUCCESS) Generate flow file input: 1234 5678 output: 1234 5678rajiv Expected output: 1234rajiv 5678rajiv ... View more