You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2020/04/25 15:01:21 UTC
[nifi] branch master updated: Do not update status for stopping a
deleted node
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 <su...@microsoft.com>
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)) {