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 871c97a21a0 NIFI-16094 Added Thread join in
TestNodeClusterCoordinator.testConnectionRequestCancelsPendingDisconnect
(#11410)
871c97a21a0 is described below
commit 871c97a21a03a2b4e1cb753a3ff463d18178b748
Author: Pierre Villard <[email protected]>
AuthorDate: Wed Jul 8 19:50:18 2026 +0200
NIFI-16094 Added Thread join in
TestNodeClusterCoordinator.testConnectionRequestCancelsPendingDisconnect
(#11410)
Signed-off-by: David Handermann <[email protected]>
---
.../nifi/cluster/coordination/node/TestNodeClusterCoordinator.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/test/java/org/apache/nifi/cluster/coordination/node/TestNodeClusterCoordinator.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/test/java/org/apache/nifi/cluster/coordination/node/TestNodeClusterCoordinator.java
index 8b03e1d57c6..80814cbb00a 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/test/java/org/apache/nifi/cluster/coordination/node/TestNodeClusterCoordinator.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/test/java/org/apache/nifi/cluster/coordination/node/TestNodeClusterCoordinator.java
@@ -56,6 +56,7 @@ import java.util.stream.Collectors;
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertInstanceOf;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
@@ -517,7 +518,8 @@ public class TestNodeClusterCoordinator {
requestConnection(nodeId2, coordinator);
assertNull(coordinator.getPendingDisconnectionThread(nodeId2));
- assertTrue(disconnectThread.isInterrupted());
+ disconnectThread.join(5000);
+ assertFalse(disconnectThread.isAlive());
}
private NodeIdentifier createNodeId(final int index) {
