Repository: nifi Updated Branches: refs/heads/master 40a9cd4f2 -> 9198bee03
NIFI-3923: Only start processors after repositories have been initialized. This closes #1817 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9198bee0 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9198bee0 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9198bee0 Branch: refs/heads/master Commit: 9198bee0382be60b90191369d8fcc99deebcb2b9 Parents: 40a9cd4 Author: Mark Payne <marka...@hotmail.com> Authored: Wed May 17 09:31:47 2017 -0400 Committer: Matt Gilman <matt.c.gil...@gmail.com> Committed: Wed May 17 11:12:59 2017 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/controller/StandardFlowSynchronizer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9198bee0/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSynchronizer.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSynchronizer.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSynchronizer.java index a9372a4..09338c9 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSynchronizer.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowSynchronizer.java @@ -731,19 +731,19 @@ public class StandardFlowSynchronizer implements FlowSynchronizer { case DISABLED: // switch processor do disabled. This means we have to stop it (if it's already stopped, this method does nothing), // and then we have to disable it. - procNode.getProcessGroup().stopProcessor(procNode); + controller.stopProcessor(procNode.getProcessGroupIdentifier(), procNode.getIdentifier()); procNode.getProcessGroup().disableProcessor(procNode); break; case RUNNING: // we want to run now. Make sure processor is not disabled and then start it. procNode.getProcessGroup().enableProcessor(procNode); - procNode.getProcessGroup().startProcessor(procNode); + controller.startProcessor(procNode.getProcessGroupIdentifier(), procNode.getIdentifier()); break; case STOPPED: if (procNode.getScheduledState() == ScheduledState.DISABLED) { procNode.getProcessGroup().enableProcessor(procNode); } else if (procNode.getScheduledState() == ScheduledState.RUNNING) { - procNode.getProcessGroup().stopProcessor(procNode); + controller.stopProcessor(procNode.getProcessGroupIdentifier(), procNode.getIdentifier()); } break; }
