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

NIFI-1941: 

- Ensuring descendent components are scheduled/unscheduled according to their respective ProcessGroups.
This commit is contained in:
Matt Gilman 2016-06-16 20:17:16 -04:00
parent 3156220a57
commit edce66d34f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/dao/impl/StandardProcessGroupDAO.java
View File

@ -106,19 +106,19 @@ public class StandardProcessGroupDAO extends ComponentDAO implements ProcessGrou
final Connectable connectable = group.findConnectable(componentId); final Connectable connectable = group.findConnectable(componentId);
if (ScheduledState.RUNNING.equals(state)) { if (ScheduledState.RUNNING.equals(state)) {
if (ConnectableType.PROCESSOR.equals(connectable.getConnectableType())) { if (ConnectableType.PROCESSOR.equals(connectable.getConnectableType())) {
group.startProcessor((ProcessorNode) connectable); connectable.getProcessGroup().startProcessor((ProcessorNode) connectable);
} else if (ConnectableType.INPUT_PORT.equals(connectable.getConnectableType())) { } else if (ConnectableType.INPUT_PORT.equals(connectable.getConnectableType())) {
group.startInputPort((Port) connectable); connectable.getProcessGroup().startInputPort((Port) connectable);
} else if (ConnectableType.OUTPUT_PORT.equals(connectable.getConnectableType())) { } else if (ConnectableType.OUTPUT_PORT.equals(connectable.getConnectableType())) {
group.startOutputPort((Port) connectable); connectable.getProcessGroup().startOutputPort((Port) connectable);
} }
} else { } else {
if (ConnectableType.PROCESSOR.equals(connectable.getConnectableType())) { if (ConnectableType.PROCESSOR.equals(connectable.getConnectableType())) {
group.stopProcessor((ProcessorNode) connectable); connectable.getProcessGroup().stopProcessor((ProcessorNode) connectable);
} else if (ConnectableType.INPUT_PORT.equals(connectable.getConnectableType())) { } else if (ConnectableType.INPUT_PORT.equals(connectable.getConnectableType())) {
group.stopInputPort((Port) connectable); connectable.getProcessGroup().stopInputPort((Port) connectable);
} else if (ConnectableType.OUTPUT_PORT.equals(connectable.getConnectableType())) { } else if (ConnectableType.OUTPUT_PORT.equals(connectable.getConnectableType())) {
group.stopOutputPort((Port) connectable); connectable.getProcessGroup().stopOutputPort((Port) connectable);
} }
} }
} }