Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

This closes #3255

Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
Peter Wicks 2019-01-09 13:03:46 -07:00 committed by Mark Payne
parent 412c4908e2
commit 35147a620f
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowService.java
View File

@ -710,7 +710,9 @@ public class StandardFlowService implements FlowService, ProtocolHandler {
.forEach(pn -> pn.getProcessGroup().terminateProcessor(pn));
// request to stop all remote process groups
flowManager.getRootGroup().findAllRemoteProcessGroups().forEach(RemoteProcessGroup::stopTransmitting);
flowManager.getRootGroup().findAllRemoteProcessGroups()
.stream().filter(rpg -> rpg.isTransmitting())
.forEach(RemoteProcessGroup::stopTransmitting);
// offload all queues on node
final Set<Connection> connections = flowManager.findAllConnections();