This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new 6c2701a Do not update status for stopping a deleted node
6c2701a is described below
commit 6c2701abef4ad3274399e946d60925be9bbecd22
Author: Sushil Kumar <[email protected]>
AuthorDate: Thu Apr 23 21:07:42 2020 -0700
Do not update status for stopping a deleted node
---
.../nifi/cluster/coordination/node/NodeClusterCoordinator.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
index e428046..717b8b4 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/node/NodeClusterCoordinator.java
@@ -1059,6 +1059,11 @@ public class NodeClusterCoordinator implements
ClusterCoordinator, ProtocolHandl
final NodeConnectionStatus oldStatus =
nodeStatuses.get(statusChangeMessage.getNodeId().getId());
+ if (oldStatus == null && updatedStatus.getState() ==
NodeConnectionState.DISCONNECTED ) {
+ // There is no need to tell that node is getting disconnected if
there was no status earlier.
+ return;
+ }
+
// Either remove the value from the map or update the map depending on
the connection state
if (statusChangeMessage.getNodeConnectionStatus().getState() ==
NodeConnectionState.REMOVED) {
if (removeNodeConditionally(nodeId, oldStatus)) {
