[
https://issues.apache.org/jira/browse/NIFI-16232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard updated NIFI-16232:
----------------------------------
Status: Patch Available (was: Open)
> 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
> Priority: Major
>
> 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)
