Hello, I am trying to write a processor which parses an input file and emits one JSON flowfile for each record in the input file. Currently we're calling session.transfer() once we encounter a fragment we want to emit. But it's not sending the new flowfiles to the next processor as it processes the input flowfile. Instead it's holding everything until the input is fully processed and releasing it all at once. Is there some way I can write the processor to emit flowfiles as soon as possible rather than waiting for everything to succeed?
Thanks, Eric
