[
https://issues.apache.org/jira/browse/NIFI-15751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18070680#comment-18070680
]
ASF subversion and git services commented on NIFI-15751:
--------------------------------------------------------
Commit 7fbc1b6a51815526a1d36f7113716a87300e3eed in nifi's branch
refs/heads/main from Kevin Doran
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=7fbc1b6a518 ]
NIFI-15751 Improve Nifi Cluster Sync with Connectors (#11079)
* NIFI-15751 Delegate connector sync from VFS to ConnectorRepository
Refactor VersionedFlowSynchronizer to delegate connector synchronization
entirely to ConnectorRepository, implementing state-aware behavior for all
ConnectorState values during flow inheritance.
- Introduce ConnectorSyncDirective (ALLOW/REJECT/REMOVE) returned by
ConnectorConfigurationProvider.verifySyncable, enabling providers to
override ScheduledState and supply working config + name
- Introduce ConnectorSyncResult enum for sync outcomes
- Move connector creation, config comparison, and lifecycle management
from VFS into StandardConnectorRepository.syncConnector
- Add configurable sync timeout (nifi.components.connectors.sync.timeout)
for waiting on transient ConnectorStates (STARTING, STOPPING, PURGING)
- Simplify VFS inheritConnectors to iterate and delegate
> Improve VersionedFlowSynchronizer compatibility with Connectors
> ---------------------------------------------------------------
>
> Key: NIFI-15751
> URL: https://issues.apache.org/jira/browse/NIFI-15751
> Project: Apache NiFi
> Issue Type: Task
> Components: Core Framework
> Reporter: Kevin Doran
> Assignee: Kevin Doran
> Priority: Major
> Time Spent: 1h 50m
> Remaining Estimate: 0h
>
> Connectors should not be synced to new nodes in the NiFi cluster if they are
> in the process of updating, as the activeFlowConfiguration could be being
> modified.
> If this happens, the VersionedFlowSynchronizer should mark the connector on
> the incoming NiFi node as invalid.
> A background thread could synchronize invalid Connectors when they are stable.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
