[NIFI-5940] Cluster Node Offload Hangs if any RPG on flow is Disabled

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Fix Version/s: 1.9.0
• Component/s: Core Framework
• Assignee: Peter Wicks
• Reporter: Peter Wicks
• Created: 09/Jan/19 18:36
• Updated: 06/Feb/19 17:44
• Resolved: 06/Feb/19 17:44

Description

If any Remote Process Group on the flow is disabled when a user starts a node Offload, then offload fails.

This is because the Offload process tries to turn off all Remote Process Group's, even if they are already disabled.

2019-01-09 17:22:00,823 ERROR [Offload Flow Files from Node] org.apache.nifi.NiFi An Unknown Error Occurred in Thread Thread[Offload Flow Files from Node,5,main]: java.lang.IllegalStateException: 33a4935b-5800-360d-9250-2179e3ef5efe is not transmitting

2019-01-09 17:22:00,823 ERROR [Offload Flow Files from Node] org.apache.nifi.NiFi

java.lang.IllegalStateException: 33a4935b-5800-360d-9250-2179e3ef5efe is not transmitting

                at org.apache.nifi.remote.StandardRemoteProcessGroup.verifyCanStopTransmitting(StandardRemoteProcessGroup.java:1333)

                at org.apache.nifi.remote.StandardRemoteProcessGroup.stopTransmitting(StandardRemoteProcessGroup.java:1036)

                at java.util.ArrayList.forEach(ArrayList.java:1249)

                at org.apache.nifi.controller.StandardFlowService.offload(StandardFlowService.java:706)

                at org.apache.nifi.controller.StandardFlowService.handleOffloadRequest(StandardFlowService.java:688)

                at org.apache.nifi.controller.StandardFlowService.access$400(StandardFlowService.java:105)

                at org.apache.nifi.controller.StandardFlowService$3.run(StandardFlowService.java:428)

                at java.lang.Thread.run(Thread.java:745)

Issue Links

• links to: GitHub Pull Request #3255