Matt Burgess created NIFI-11305:
-----------------------------------
Summary: CaptureChangeMySQL does not stop if the queue is not empty
Key: NIFI-11305
URL: https://issues.apache.org/jira/browse/NIFI-11305
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Reporter: Matt Burgess
There is a logic bug in the handling of stopping the CaptureChangeMySQL
processor. This causes it to not stop while there are events in the queue. If
the processor isn't running fast enough to drain the queue, stopping the
processor will have no effect.
The logic was being handled in OnStopped, but that won't get called until the
onTrigger has finished. Instead the loop should be checking to see if the
processor is still scheduled using isScheduled(), and if not should break out
of the loop and finish the onTrigger processing, thereby allowing the OnStopped
logic to be executed.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)