This is an automated email from the ASF dual-hosted git repository.
pvillard 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 979d22aa20 NIFI-14772 Fixed System Test for components recreated
979d22aa20 is described below
commit 979d22aa20e3039e2aaab21ba9e349848b0f5dda
Author: exceptionfactory <[email protected]>
AuthorDate: Wed Jul 23 20:25:17 2025 -0500
NIFI-14772 Fixed System Test for components recreated
- Added wait for Processor running before stopping Node 2
Signed-off-by: Pierre Villard <[email protected]>
This closes #10131.
---
.../org/apache/nifi/tests/system/clustering/FlowSynchronizationIT.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/clustering/FlowSynchronizationIT.java
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/clustering/FlowSynchronizationIT.java
index 772685fb00..476d873bbc 100644
---
a/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/clustering/FlowSynchronizationIT.java
+++
b/nifi-system-tests/nifi-system-test-suite/src/test/java/org/apache/nifi/tests/system/clustering/FlowSynchronizationIT.java
@@ -449,13 +449,14 @@ public class FlowSynchronizationIT extends NiFiSystemIT {
getClientUtil().updateReportingTaskProperties(reportingTask,
reportingTaskProperties);
// Start everything up on Node 1.
- getClientUtil().enableControllerService(countService);
getClientUtil().enableControllerService(sleepService);
+ getClientUtil().enableControllerService(countService);
getClientUtil().startReportingTask(reportingTask);
getClientUtil().waitForValidProcessor(count.getId()); // Now that
service was enabled, wait for processor to become valid.
getClientUtil().startProcessGroupComponents(group.getId());
getClientUtil().startProcessor(terminate);
getClientUtil().startProcessor(generate);
+ getClientUtil().waitForProcessorState(count.getId(), RUNNING_STATE);
// Stop & restart Node 2.
getNiFiInstance().getNodeInstance(2).stop();
