Pierre Villard created NIFI-16232:
-------------------------------------
Summary: Allow versioned flow updates to drain removed connections
Key: NIFI-16232
URL: https://issues.apache.org/jira/browse/NIFI-16232
Project: Apache NiFi
Issue Type: Improvement
Reporter: Pierre Villard
Assignee: Pierre Villard
A versioned flow update currently stops both endpoints of a connection before
verifying that a connection removed in the target version has an empty queue.
Because the destination is already stopped, queued FlowFiles cannot drain, and
the update fails even when the destination could otherwise process the
remaining data.
The goal is to add an Update-only pre-drain phase that conservatively
identifies eligible removed connections, stops their producers, and allows
running destinations up to 30 seconds to drain the queues. The existing
connection-removal safety checks remain unchanged. Unsupported topologies fail
before runtime changes, while timeout and cancellation restore components
stopped by the pre-drain phase.
The implementation supports standalone and clustered deployments with exact
per-node queue-status coverage.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
