Skip to content

NIFI-16378: Handle disabled Processors during Connector drain - #11709

Open
markap14 wants to merge 1 commit into
apache:mainfrom
markap14:nifi-16378
Open

markap14 wants to merge 1 commit into
apache:mainfrom
markap14:nifi-16378

Conversation

@markap14

Copy link
Copy Markdown
Contributor

Summary

  • Connector drain never finished when the Connector flow contained a disabled Processor, because Processor lifecycle stop() always waited on the scheduler.
  • StandaloneProcessorLifecycle.stop() now returns a completed future when the Processor is already physically stopped or disabled, matching Process Group stop handling.
  • ConnectorDrainIT.testDrainFlowFiles now includes a disabled Processor in the gated drain flow so this path is covered.

Test plan

  • ConnectorDrainIT#testDrainFlowFiles failed with a timeout while waiting for drain to complete on the original code
  • Same test passes after the lifecycle change
  • ConnectorDrainIT (full class) passes
  • nifi-framework-core unit tests, Checkstyle, and PMD pass

Jira: https://issues.apache.org/jira/browse/NIFI-16378

Co-authored-by: Cursor <cursoragent@cursor.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant