[
https://issues.apache.org/jira/browse/NIFI-16490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18130613#comment-18130613
]
ASF subversion and git services commented on NIFI-16490:
--------------------------------------------------------
Commit 8d4d520ad2a6e9a70601319c3bb04977b0cccd59 in nifi's branch
refs/heads/main from Pierre Villard
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=8d4d520ad2a ]
NIFI-16490 Return Cluster Members from the Cluster Coordinator during flow
synchronization (#11834)
Signed-off-by: David Handermann <[email protected]>
> Return cluster members from the cluster coordinator during flow
> synchronization
> -------------------------------------------------------------------------------
>
> Key: NIFI-16490
> URL: https://issues.apache.org/jira/browse/NIFI-16490
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Core Framework
> Reporter: Pierre Villard
> Assignee: Pierre Villard
> Priority: Major
> Time Spent: 20m
> Remaining Estimate: 0h
>
> FlowController.getClusterMembers() currently returns an empty set until
> isClustered() is true. When a node connects to a cluster,
> StandardFlowService.loadFromConnectionResponse loads the full list of node
> connection statuses from the connection response into the local cluster
> coordinator (initializeNodeConnectionState). It does this before the flow
> sync (loadFromBytes) runs. However, clustered is only set to true after the
> sync completes.
> Controller Services and other components are enabled during that sync. During
> that window, NodeTypeProvider.getClusterMembers() returns nothing, even
> though the node already knows the cluster membership, joining node included.
> So components cannot tell a single-node cluster restarting apart from a node
> joining an existing multi-node cluster. Either case looks like zero members.
> This change updates getClusterMembers() to return the coordinator's node list
> whenever the node is configured for clustering, not only once isClustered()
> is true. Reading the list requires no FlowController locks, consistent withÂ
> NIFI-16153 and NIFI-16383. Standalone (non-clustered) instances keep
> returning an empty set.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
