(nifi) branch main updated: NIFI-15764 Fixed Disconnected Node handling in Connector System Tests (#11071)

[exceptionfactory]

This is an automated email from the ASF dual-hosted git repository.

exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new e8a5ce1813c NIFI-15764 Fixed Disconnected Node handling in Connector 
System Tests (#11071)
e8a5ce1813c is described below

commit e8a5ce1813c9d3f9da85a957a8f8c85a29cc7bc7
Author: Pierre Villard <pierre.villard...@gmail.com>
AuthorDate: Mon Mar 30 23:12:36 2026 +0200

    NIFI-15764 Fixed Disconnected Node handling in Connector System Tests 
(#11071)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../src/test/java/org/apache/nifi/tests/system/NiFiClientUtil.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/NiFiClientUtil.java
 
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/NiFiClientUtil.java
index 053615d2121..17de5d0ce14 100644
--- 
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/NiFiClientUtil.java
+++ 
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/NiFiClientUtil.java
@@ -401,6 +401,7 @@ public class NiFiClientUtil {
     public void stopConnectors() throws NiFiClientException, IOException, 
InterruptedException {
         final ConnectorsEntity connectorsEntity = 
nifiClient.getFlowClient().getConnectors();
         for (final ConnectorEntity connector : 
connectorsEntity.getConnectors()) {
+            connector.setDisconnectedNodeAcknowledged(true);
             getConnectorClient().stopConnector(connector);
             waitForConnectorStopped(connector.getId());
         }
@@ -412,6 +413,7 @@ public class NiFiClientUtil {
 
     public void startConnector(final String connectorId) throws 
NiFiClientException, IOException, InterruptedException {
         final ConnectorEntity entity = 
getConnectorClient().getConnector(connectorId);
+        entity.setDisconnectedNodeAcknowledged(true);
         getConnectorClient().startConnector(entity);
         waitForConnectorState(connectorId, ConnectorState.RUNNING);
     }
@@ -422,6 +424,7 @@ public class NiFiClientUtil {
 
     public void stopConnector(final String connectorId) throws 
NiFiClientException, IOException, InterruptedException {
         final ConnectorEntity entity = 
getConnectorClient().getConnector(connectorId);
+        entity.setDisconnectedNodeAcknowledged(true);
         getConnectorClient().stopConnector(entity);
         waitForConnectorStopped(connectorId);
     }
@@ -449,11 +452,13 @@ public class NiFiClientUtil {
 
     public ConnectorEntity drainConnector(final String connectorId) throws 
NiFiClientException, IOException {
         final ConnectorEntity entity = 
getConnectorClient().getConnector(connectorId);
+        entity.setDisconnectedNodeAcknowledged(true);
         return getConnectorClient().drainConnector(entity);
     }
 
     public ConnectorEntity cancelDrain(final String connectorId) throws 
NiFiClientException, IOException {
         final ConnectorEntity entity = 
getConnectorClient().getConnector(connectorId);
+        entity.setDisconnectedNodeAcknowledged(true);
         return getConnectorClient().cancelDrain(entity);
     }