Alessio, Without seeing your modifications, I am guessing that session.transfer() is being called multiple times for the same flow file. Can you share your onTrigger() code? If not, take a look to see if there is a loop or other path that could cause session.transfer() to be called on the same flow file more than once.
Regards, Matt On Wed, Feb 1, 2017 at 8:26 AM, Alessio Palma <[email protected]> wrote: > Hello all, > > I'm working to a processor and a service. > > My work is based on source codes from > https://github.com/pcgrenier/nifi-examples/tree/sample-processor > > > My problem is this code > > > runner = TestRunners.newTestRunner(new StartProcessor()); > > : > > . > > > runner.enqueue("THIS IS A CONTENT".getBytes()); > runner.run(1); > > which stops with : > > IllegalStateException: FlowFile[1,71039521870109.mockFlowFile,0B] has already > been transferred > > runner.run(1) ---> looks like is missing the contente I put into the queue. > > What is the correct way to add a fake flowfile into the queue? > What's wrong with the above code ? > > Thanks in advance. > AP >
