For this usecase the most natural solution is probably as follows: 1. Send message to a script for processing 2. Let the script turn your 1 row into an output of N rows  3. Optional: Split the rows in Nifi   ... View more

@budati  If you cannot get the blank space in, then just go back to the default of ; and add it between the parameters in the Command Arguments property. ... View more

@budati    For this case define your avro schema(with one field) to read incoming flowfile with some delimiter that doesn't exist in flowfile.   So that whole row will be read as string then we can filter out the records by using not like (or) using regex operator in apache calicite.   Select * from flowfile where col1 not like 'SKIP' Now output flowfile will not having any records that have SKIP in them and this solution will work dynamically for any number of columns. ... View more

@budati  i don't think there is a way to combine all 3 processors into one.   We still need to use ExecuteSQL -> ConvertAvroToJson -> EvaluateJsonPath to extract the values from the flowfile.   If the answer was helpful to resolve your issue, Accept the answer to close the thread 🙂 ... View more