[jira] [Commented] (NIFI-5162) Registry Client should throttle repeated failure calls

["Bryan Bende (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/NIFI-5162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466177#comment-16466177 ] 

Bryan Bende commented on NIFI-5162:
-----------------------------------

Every 60 seconds it checks the status of all versioned controlled process group, so you should see a flurry of errors (1 per version controlled PG) then a pause for 60 seconds, then errors again, etc.  is that what you are seeing?

Maybe we can stop checking the remaining PGs if we encounter a forbidden exception or IO exception, since likely the remainder of them will also fail with the same error.

> Registry Client should throttle repeated failure calls
> ------------------------------------------------------
>
>                 Key: NIFI-5162
>                 URL: https://issues.apache.org/jira/browse/NIFI-5162
>             Project: Apache NiFi
>          Issue Type: Improvement
>            Reporter: Joseph Percivall
>            Priority: Major
>
> In the event that the controller cannot connect to the Registry instance, it will repeatedly send requests as fast as possible that flood the logs with errors. Also, none of these errors are displayed to the user in the UI. Below is an example:
>  
> {quote}{{2018-05-07 13:59:28,295 ERROR [Timer-Driven Process Thread-15] o.a.nifi.groups.StandardProcessGroup Failed to synchronize StandardProcessGroup[identifier=8f17ccb9-015c-1000-d297-8071b46cf5fe] with Flow Registry because could not retrieve version 1 of flow with identifier 60cb4fec-393c-46d0-bd9e-466a97f71a35 in bucket 3654768f-0762-45c0-9e0f-0fccf04f8402}}
> {{org.apache.nifi.registry.client.NiFiRegistryException: Error retrieving flow snapshot: Unknown user with identity 'CN=fake-CN, OU=Hosts, O=Fake Org, C=ZZ'. Contact the system administrator.}}
> {{ at org.apache.nifi.registry.client.impl.AbstractJerseyClient.executeAction(AbstractJerseyClient.java:85)}}
> {{ at org.apache.nifi.registry.client.impl.JerseyFlowSnapshotClient.get(JerseyFlowSnapshotClient.java:96)}}
> {{ at org.apache.nifi.registry.flow.RestBasedFlowRegistry.getFlowContents(RestBasedFlowRegistry.java:206)}}
> {{ at org.apache.nifi.registry.flow.RestBasedFlowRegistry.getFlowContents(RestBasedFlowRegistry.java:220)}}
> {{ at org.apache.nifi.groups.StandardProcessGroup.synchronizeWithFlowRegistry(StandardProcessGroup.java:3231)}}
> {{ at org.apache.nifi.controller.FlowController$4.run(FlowController.java:786)}}
> {{ at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)}}
> {{ at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)}}
> {{ at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)}}
> {{ at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)}}
> {{ at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)}}
> {{ at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)}}
> {{ at java.lang.Thread.run(Thread.java:748)}}
> {{Caused by: javax.ws.rs.ForbiddenException: HTTP 403 Forbidden}}
> {{ at org.glassfish.jersey.client.JerseyInvocation.convertToException(JerseyInvocation.java:1083)}}
> {{ at org.glassfish.jersey.client.JerseyInvocation.translate(JerseyInvocation.java:883)}}
> {{ at org.glassfish.jersey.client.JerseyInvocation.lambda$invoke$1(JerseyInvocation.java:767)}}
> {{ at org.glassfish.jersey.internal.Errors.process(Errors.java:316)}}
> {{ at org.glassfish.jersey.internal.Errors.process(Errors.java:298)}}
> {{ at org.glassfish.jersey.internal.Errors.process(Errors.java:229)}}
> {{ at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:414)}}
> {{ at org.glassfish.jersey.client.JerseyInvocation.invoke(JerseyInvocation.java:765)}}
> {{ at org.glassfish.jersey.client.JerseyInvocation$Builder.method(JerseyInvocation.java:428)}}
> {{ at org.glassfish.jersey.client.JerseyInvocation$Builder.get(JerseyInvocation.java:324)}}
> {{ at org.apache.nifi.registry.client.impl.JerseyFlowSnapshotClient.lambda$get$1(JerseyFlowSnapshotClient.java:103)}}
> {{ at org.apache.nifi.registry.client.impl.AbstractJerseyClient.executeAction(AbstractJerseyClient.java:71)}}
> {{ ... 12 common frames omitted}}
> {quote}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)