nifi-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael De Courci <mdecou...@gmail.com>
Subject Fwd: NiFI Custom Plugin - Yield Duration Ignored
Date Tue, 17 Nov 2015 15:34:31 GMT
FYI

> Begin forwarded message:
> 
> From: Michael De Courci <mdecourci@googlemail.com>
> Date: 16 November 2015 at 15:41:27 GMT
> To: users@nifi.apache.org, Michael.DeCourci@barclayscapital.com, Kefah Issa <kefah.issa@barclays.com>
> 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


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message