You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Arnaud G (Jira)" <ji...@apache.org> on 2022/04/12 08:21:00 UTC
[jira] [Created] (NIFI-9912) offloaded nodes cannot rejoin the cluster
Arnaud G created NIFI-9912:
------------------------------
Summary: offloaded nodes cannot rejoin the cluster
Key: NIFI-9912
URL: https://issues.apache.org/jira/browse/NIFI-9912
Project: Apache NiFi
Issue Type: Bug
Components: Core Framework
Affects Versions: 1.16.0
Environment: Official Nifi docker image
Reporter: Arnaud G
When a node is in an offloaded state, the node will never reconnect to the cluster if instructed to do it.
It will raise the following exception (please note that no modification was made to the flow map):
2022-04-11 08:16:09,050 ERROR [Reconnect to Cluster] o.a.nifi.controller.StandardFlowService Handling reconnection request failed due to: org.apache.nifi.controller.serialization.FlowSynchronizationException: Failed to connect node to cluster because local flow controller partially updated. Administrator should disconnect node and review flow for corruption. org.apache.nifi.controller.serialization.FlowSynchronizationException: Failed to connect node to cluster because local flow controller partially updated. Administrator should disconnect node and review flow for corruption. at org.apache.nifi.controller.StandardFlowService.loadFromConnectionResponse(StandardFlowService.java:1057) at org.apache.nifi.controller.StandardFlowService.handleReconnectionRequest(StandardFlowService.java:665) at org.apache.nifi.controller.StandardFlowService.access$200(StandardFlowService.java:108) at org.apache.nifi.controller.StandardFlowService$1.run(StandardFlowService.java:396) at java.lang.Thread.run(Thread.java:750) Caused by: org.apache.nifi.controller.serialization.FlowSynchronizationException: java.lang.IllegalStateException: Cannot modify Processor configuration while the Processor is running at org.apache.nifi.controller.serialization.VersionedFlowSynchronizer.synchronizeFlow(VersionedFlowSynchronizer.java:362) at org.apache.nifi.controller.serialization.VersionedFlowSynchronizer.sync(VersionedFlowSynchronizer.java:185) at org.apache.nifi.controller.serialization.StandardFlowSynchronizer.sync(StandardFlowSynchronizer.java:43) at org.apache.nifi.controller.FlowController.synchronize(FlowController.java:1479) at org.apache.nifi.persistence.StandardFlowConfigurationDAO.load(StandardFlowConfigurationDAO.java:104) at org.apache.nifi.controller.StandardFlowService.loadFromBytes(StandardFlowService.java:815) at org.apache.nifi.controller.StandardFlowService.loadFromConnectionResponse(StandardFlowService.java:1026) ... 4 common frames omitted Caused by: java.lang.IllegalStateException: Cannot modify Processor configuration while the Processor is running at org.apache.nifi.controller.StandardProcessorNode.setPenalizationPeriod(StandardProcessorNode.java:651) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.updateProcessor(StandardProcessGroupSynchronizer.java:1583) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronizeProcessors(StandardProcessGroupSynchronizer.java:835) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronize(StandardProcessGroupSynchronizer.java:379) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronizeChildGroups(StandardProcessGroupSynchronizer.java:437) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronize(StandardProcessGroupSynchronizer.java:373) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronizeChildGroups(StandardProcessGroupSynchronizer.java:437) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronize(StandardProcessGroupSynchronizer.java:373) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.lambda$synchronize$0(StandardProcessGroupSynchronizer.java:221) at org.apache.nifi.controller.flow.AbstractFlowManager.withParameterContextResolution(AbstractFlowManager.java:462) at org.apache.nifi.groups.StandardProcessGroupSynchronizer.synchronize(StandardProcessGroupSynchronizer.java:219) at org.apache.nifi.groups.StandardProcessGroup.synchronizeFlow(StandardProcessGroup.java:3830) at org.apache.nifi.controller.serialization.VersionedFlowSynchronizer.synchronizeFlow(VersionedFlowSynchronizer.java:353) ... 10 common frames omitted
If the node is restarted it will rejoin the cluster without issue.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)