[jira] [Created] (NIFI-9293) Stateless engine does not stop processors properly

["Peter Turcsanyi (Jira)" <ji...@apache.org>]

Peter Turcsanyi created NIFI-9293:
-------------------------------------

             Summary: Stateless engine does not stop processors properly
                 Key: NIFI-9293
                 URL: https://issues.apache.org/jira/browse/NIFI-9293
             Project: Apache NiFi
          Issue Type: Bug
          Components: NiFi Stateless
            Reporter: Peter Turcsanyi


When the embedding application calls {{StatelessDataflow.shutdown()}} to stop the stateless flow and all its processors, then the expected behaviour would be (similar to traditional NiFi):
- call {{@OnUnscheduled}} method(s) of the processor
- wait for {{onTrigger()}} to finish up
- call {{@OnStopped}} method(s) of the processor

Currently {{@OnUnscheduled}} is not called at all and {{@OnStopped}} gets called while {{onTrigger()}} is still running.
These may lead to improper shutdown of the components: e.g. ConsumeJMS stays connected to the message broker after is has been stopped (up until the JVM exits).
It is more problematic for long-running embedding applications that can start/stop flows dynamically within their JVM uptime (like Kafka Connect and NiFi Stateless connectors).



--
This message was sent by Atlassian Jira
(v8.3.4#803005)