This is an automated email from the ASF dual-hosted git repository.
bbende pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from b77dbd5 NIFI-8172: Provide schema name to getPrimaryKeys call in
PutDatabaseRecord
new 03fd59e NIFI-8196: When node is reconnected to cluster, ensure that
it re-registers for election of cluster coordinator / primary node. On startup,
if cluster coordinator is already registered and is 'this node' then register
silently as coordinator and do not join the cluster until there is no Cluster
Coordinator or another node is elected. This allows the zookeeper session
timeout to elapse.
new 749d058 NIFI-8204, NIFI-7866: Send revision update count in
heartbeats. If update count in heartbeat is greater than that of cluster
coordinator, request that node reconnect to get most up-to-date revisions.
Cannot check exact equality, as the values may change between the time a
heartbeat is created and the time the cluster coordinator receives it. However,
it should be safe to assume that the revision won't be greater than that of the
cluster coordinator. There is a tiny windo [...]
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
nifi-docs/src/main/asciidoc/getting-started.adoc | 4 +-
nifi-docs/src/main/asciidoc/walkthroughs.adoc | 18 +++---
.../cluster/coordination/ClusterCoordinator.java | 7 +++
.../coordination/heartbeat/NodeHeartbeat.java | 5 ++
.../protocol/AbstractNodeProtocolSender.java | 49 +++++++++++++---
.../protocol/ComponentRevisionSnapshot.java | 66 ++++++++++++++++++++++
.../nifi/cluster/protocol/ConnectionResponse.java | 14 ++---
.../nifi/cluster/protocol/HeartbeatPayload.java | 24 +++++---
.../nifi/cluster/protocol/NodeProtocolSender.java | 3 +-
.../protocol/impl/NodeProtocolSenderListener.java | 10 ++--
.../jaxb/message/AdaptedConnectionResponse.java | 15 +++--
.../message/ReconnectionRequestMessage.java | 17 +++---
.../jaxb/message/TestJaxbProtocolUtils.java | 48 +++++++++-------
.../heartbeat/AbstractHeartbeatMonitor.java | 2 +
.../heartbeat/ClusterProtocolHeartbeatMonitor.java | 5 +-
.../heartbeat/StandardNodeHeartbeat.java | 11 +++-
.../coordination/node/NodeClusterCoordinator.java | 36 ++++++++++--
.../heartbeat/TestAbstractHeartbeatMonitor.java | 2 +-
.../node/TestNodeClusterCoordinator.java | 10 ++--
.../org/apache/nifi/cluster/integration/Node.java | 7 ++-
.../apache/nifi/web/revision/RevisionManager.java | 12 ++--
.../apache/nifi/web/revision/RevisionSnapshot.java | 42 +++++++++-----
.../org/apache/nifi/controller/FlowController.java | 42 ++++++++------
.../nifi/controller/StandardFlowService.java | 40 +++++++++++--
.../election/CuratorLeaderElectionManager.java | 43 +++++++++++++-
.../leader/election/LeaderElectionManager.java | 7 +++
.../election/StandaloneLeaderElectionManager.java | 5 ++
.../zookeeper/ZooKeeperStateProvider.java | 4 +-
.../nifi/spring/FlowControllerFactoryBean.java | 9 ++-
.../src/main/resources/nifi-context.xml | 1 +
.../nifi/controller/StandardFlowServiceTest.java | 17 +++---
.../nifi/controller/StandardProcessorNodeIT.java | 56 +++++++++---------
.../reporting/TestStandardReportingContext.java | 17 +++---
.../nifi/integration/FrameworkIntegrationTest.java | 3 +-
.../apache/nifi/headless/HeadlessNiFiServer.java | 3 +-
.../nifi/web/revision/NaiveRevisionManager.java | 43 +++++++++-----
.../clustering/JoinClusterWithDifferentFlow.java | 52 ++++++++++-------
.../system/parameters/ParameterContextIT.java | 5 +-
38 files changed, 533 insertions(+), 221 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/protocol/ComponentRevisionSnapshot.java
copy nifi-api/src/main/java/org/apache/nifi/parameter/Parameter.java =>
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/web/revision/RevisionSnapshot.java
(51%)
