FYI
> Begin forwarded message:
>
> From: Michael De Courci <[email protected]>
> Date: 16 November 2015 at 15:41:27 GMT
> To: [email protected], [email protected], Kefah Issa
> <[email protected]>
> Subject: NiFI Custom Plugin - Yield Duration Ignored
>
> I wrote a NAR custom plugin to verify NoFi Exception handling. - version;
> nifi-0.3.0
>
> The plugin was written to always through a RunTimeException for any exception
> including ProcessException.
>
> I created a simple flow; GetFile->MyPlugin->PutFile
>
> and set the Yield duration to 60 seconds.
>
> The log shows that the yield duration is always 1 sec
>
> I debugged the NiFi framework code and see that the yield duration always
> defaults to 1 sec;
> See;
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent
>
> Setting the duration updates the class
> org.apache.nifi.controller.StandardProcessorNode
> but this does not communicate the change to TimerDrivenSchedulingAgent
>
> Evidence from log;
>
> 80eb-552a-471c-8ffd-f2509d71fd2e] failed to process session due to
> java.lang.RuntimeException: java.lang.RuntimeException
>
> 2015-11-15 16:17:58,417 WARN [Timer-Driven Process Thread-7]
> c.b.n.p.SampleErrorHandlerProcessor
> SampleErrorHandlerProcessor[id=8e8f80eb-552a-471c-8ffd-f2509d71fd2e]
> Processor Administratively Yielded for 1 sec due to processing failure
>
> 2015-11-15 16:17:58,417 WARN [Timer-Driven Process Thread-7]
> o.a.n.c.t.ContinuallyRunProcessorTask Administratively Yielding
> SampleErrorHandlerProcessor[id=8e8f80eb-552a-471c-8ffd-f2509d71fd2e] due to
> uncaught Exception: java.lang.RuntimeException
>
> 2015-11-15 16:17:58,419 WARN [Timer-Driven Process Thread-7]
> o.a.n.c.t.ContinuallyRunProcessorTask
>
> java.lang.RuntimeException: null
>
> at
> com.barclays.nifi.processor.SampleErrorHandlerProcessor.onTrigger(SampleErrorHandlerProcessor.scala:103)
> ~[na:na]
>
>
>
> With Kind Regards
> Michael de Courci
