[
https://issues.apache.org/jira/browse/NIFI-5162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466257#comment-16466257
]
Joseph Percivall commented on NIFI-5162:
----------------------------------------
Yup, looking again that is what I'm seeing. Was confused as we have 30+
versioned PGs and the logs are flooded with stack traces. Looking at the
timestamp, they are a flood every minute.
Yup, I agree with that approach, a similar case as yielding a processor vs
penalizing a FF. When there is something that would affect all the versioned
PGs, just fail fast.
> 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)
