Hello everybody,

I have 2 questions:

1.       Is there some way to find out through which relationship/queue a 
FlowFile walked into a processor, in the onTrigger-Method?

2.       Is there a generic way how errors (e.g. Exceptions) are propagated 
with FlowFiles to subsequent processors?

Background Story:
I am writing a failure processor which handles failure events from FetchSFTP 
outgoing relationships, writing some flowfile attributes into a database and 
performing some further tasks to cope with the error. Now I would like to know 
through which of the three failure-reporting-relationships the FlowFile came 
along and get some generic failure information (e.g. the Exception). Right now 
I am adding 3 UpdateAttribute processors which each add an attribute 
identifying the relationship (and thereby the type of error). Maybe there is a 
better way to do this? I am using NiFi 1.0.

Thank you very much for any help you might provide.
Kind regards,
Andreas Petter

Reply via email to