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

NIFI-5066: 

- Fixing predicate for finding all processors/ports that can be disabled.

This closes #2739.

Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
Matt Gilman 2018-05-25 08:08:50 -04:00 committed by Mark Payne
parent 18ec386150
commit dbef69040f
1 changed files with 2 additions and 2 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-api/src/main/java/org/apache/nifi/groups/ProcessGroup.java
View File

@ -75,7 +75,7 @@ public interface ProcessGroup extends ComponentAuthorizable, Positionable, Versi
/** /**
* Predicate for disabling eligible Processors. * Predicate for disabling eligible Processors.
*/ */
Predicate<ProcessorNode> DISABLE_PROCESSORS_FILTER = node -> !node.isRunning(); Predicate<ProcessorNode> DISABLE_PROCESSORS_FILTER = node -> !node.isRunning() && !ScheduledState.DISABLED.equals(node.getScheduledState());
/** /**
* Predicate for starting eligible Ports. * Predicate for starting eligible Ports.
@ -95,7 +95,7 @@ public interface ProcessGroup extends ComponentAuthorizable, Positionable, Versi
/** /**
* Predicate for disabling eligible Ports. * Predicate for disabling eligible Ports.
*/ */
Predicate<Port> DISABLE_PORTS_FILTER = port -> !port.isRunning(); Predicate<Port> DISABLE_PORTS_FILTER = port -> !port.isRunning() && !ScheduledState.DISABLED.equals(port.getScheduledState());
/** /**
* @return a reference to this ProcessGroup's parent. This will be * @return a reference to this ProcessGroup's parent. This will be