NIFI-5944: If processor is no longer scheduled to run after a failed trigger of ...
authorMark Payne <markap14@hotmail.com>
Thu, 10 Jan 2019 21:33:55 +0000 (16:33 -0500)
committerMatt Gilman <matt.c.gilman@gmail.com>
Fri, 11 Jan 2019 15:22:22 +0000 (10:22 -0500)
This closes #3263

nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java

index 8ca5173..a68eaab 100644 (file)
@@ -1485,6 +1485,7 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
             if (currentScheduleState == ScheduledState.STOPPING || currentScheduleState == ScheduledState.STOPPED) {
                 LOG.debug("{} is stopped. Will not call @OnScheduled lifecycle methods or begin trigger onTrigger() method", StandardProcessorNode.this);
                 schedulingAgentCallback.onTaskComplete();
+                scheduledState.set(ScheduledState.STOPPED);
                 return null;
             }